RPf UddlmZddlmZddlmZmZddlmZm Z ddl m Z m Z m Z mZddlZddlZddlmZmZdd lmZdad ed <dad ed <daddZe ddZddZddZej<dddZej<dd dZ ejBded!dZ"ejBd"dZ#ejBd#dZ$y)$) annotations)Iterator) ExitStackcontextmanager)isasyncgenfunctioniscoroutinefunction)AnyDictTuplecastN)get_all_backendsget_async_backend) TestRunnerzTestRunner | None_current_runnerzExitStack | None _runner_stackct|tr|ifSt|tr^t|dk(rPt|dtr=t|dtr*t t ttttff|Std)Nrr z@anyio_backend must be either a string or tuple of (string, dict)) isinstancestrtuplelendictr r r r TypeError)backends M/var/www/fastapitest/venv/lib/python3.12/site-packages/anyio/pytest_plugin.pyextract_backend_and_optionsrsq'3{ GU #G (9 gaj# &:gaj$+Gc4S>12G< < V WWc#\Ktt|}tatj j dMtj j|}tjtj j||xsi}tj|j|atdz a ttdza ts!tJtjdxaayy#tdza ts!tJtjdxaawwxYwwNr )rrrrsniffiocurrent_async_library_cvargetsetcallbackreset enter_contextcreate_test_runner_runner_leasesclose) backend_namebackend_optionsasynclibtokens r get_runnerr/s $\2!  - - 1 1$ 7 ?66::<HE  " "7#E#E#K#KU S)/R'55  ' ' 8 aN3! , ,,    !.2 2MO ! , ,,    !.2 2MOsB;D,>C71D,72D))D,c(|jddy)NmarkerszManyio: mark the (coroutine function) test to be run asynchronously via anyio.)addinivalue_line)configs rpytest_configurer4;s  $rcfd}|jts tr=d|jvr.d|jv||_s|xjdz c_yyyy)Nc?Kt|\}}r||d<t||5}tr|j|Ed{n|j |dddy7"#1swYyxYww)N anyio_backend)rr/rrun_asyncgen_fixture run_fixture)r7argskwargsr+r,runnerfunchas_backend_args rwrapperz%pytest_fixture_setup..wrapperDs}(CM(R% o &3F? #  o 6 7&!$'!66tVDDD((v66  7 7D 7 7s."A7!A+A)A+ A7)A++A40A7r7r7)r=rr fixturenamesargnames) fixturedefrequestr?r=r>s @@rpytest_fixture_setuprECsl 7 ??D$#6t#< g22 2-1D1DDO%JO"##'99## 3$=rT)tryfirstc8|j||rt|dr|jjn|}t |rX|j d}t |dd}|std|Dr%tjjd|yyyy)N hypothesisanyio pytestmarkc3:K|]}|jdk(yw)rIN)name).0markers r z,pytest_pycollect_makeitem..asNV[[G3Nsr7) istestfunctionhasattrrH inner_testrget_closest_markergetattranypytestmark usefixtures) collectorrMobj inner_funcrO own_markerss rpytest_pycollect_makeitemr^ZsT*29#|2LS^^..RU z *11':F!#|R8KN+NN ''8=O ++rcr d fd }|jjd}|rt|\t|jdr`|jj j j|jk7r&t r||jj _yt|jre|j}|jjDcic]}||| }}t5}|j|j|dddyycc}w#1swYyxYw)Nclt5}|j|dddy#1swYyxYwN)r/run_test)r;r<r+r, original_funcs rrun_with_hypothesisz/pytest_pyfunc_call..run_with_hypothesisgs2  o 6 3& OOM6 2 3 3 3s*3r7rHT)r;r returnNone) funcargsr#rrRr[rHrS __qualname__r _fixtureinforBr/rb) pyfuncitemrdrrgargtestargsr<r+r,rcs @@@rpytest_pyfunc_callrmes3!!%%o6G(CG(L% o :>>< 0&NN55@@M))-@-M-MM&}5;NJNN--8 z~~ .!**H6@6M6M6V6VWsXc]*WHWL/: :f 9 :  X :s& D(D--D6module)scopeparamsc|jSra)param)rDs rr7r7s ==rc0t|tr|S|dS)Nrrrr@s ranyio_backend_namerus-%Qrc0t|triS|dSr rtr@s ranyio_backend_optionsrws-% Qr)robjectreztuple[str, dict[str, Any]])r+rr,dict[str, Any]rezIterator[TestRunner])r3r rerf)rCr rDr rerf)rZr rMr r[r rerf)rjr rez bool | None)rDr rer )r7r rer)r7r rery)% __future__rcollections.abcr contextlibrrinspectrrtypingr r r r rWr!_core._eventlooprrabcrr__annotations__rr)rr/r4rEhookimplr^rmfixturer7rurwrKrrrs "$0;)) A%)")"& &X33(6333::.$> >$ :h'7'9:;    r