ܲe UddlmZddlmZddlmZmZddlmZm Z ddl m Z m Z m Z mZddlZddlZddlmZmZdd lmZdad ed <dad ed <dad/dZed0dZd1dZd2dZejd !d3d%Zejd !d4d(Z ej!d)e*d5d+Z"ej!d6d-Z#ej!d7d.Z$dS)8) annotations)Iterator) ExitStackcontextmanager)isasyncgenfunctioniscoroutinefunction)AnyDictTuplecastN)get_all_backendsget_async_backend) TestRunnerzTestRunner | None_current_runnerzExitStack | None _runner_stackbackendobjectreturntuple[str, dict[str, Any]]ct|tr|ifSt|trt|dkrot|dtrTt|dtr9t t ttttff|Std)Nrr z@anyio_backend must be either a string or tuple of (string, dict)) isinstancestrtuplelendictr r r r TypeError)rs 3lib/python3.11/site-packages/anyio/pytest_plugin.pyextract_backend_and_optionsr s'3={ GU # #=G (9(9 gaj# & & =:gaj$+G+G =c4S>12G<< < V W WW backend_namerbackend_optionsdict[str, Any]Iterator[TestRunner]c#Ktt|}tatjdItj|}ttjj ||pi}t | |atdz a tVtdza ts(tJt dxaadSdS#tdza ts&tJt dxaawxYwNr )rrrrsniffiocurrent_async_library_cvargetsetcallbackreset enter_contextcreate_test_runner_runner_leasesclose)r"r#asynclibtokens r get_runnerr4sM $\22!  - 1 1$ 7 7 ?6::<HHE  " "7#E#KU S S S)/R'55  ' ' 8 8  aN3! 3 ,,,    ! ! !.2 2MOOO 3 3 ! 3 ,,,    ! ! !.2 2MO 2 2 2 2s D9Econfigr Nonec2|dddS)NmarkerszManyio: mark the (coroutine function) test to be run asynchronously via anyio.)addinivalue_line)r5s rpytest_configurer:;s,  $r! fixturedefrequestcfd}|jtstr/d|jvr$d|jv||_s|xjdz c_dSdSdSdS)Nc?Kt|\}}r||d<t||5}tr||Ed{Vn||VddddS#1swxYwYdS)N anyio_backend)r r4rrun_asyncgen_fixture run_fixture)r?argskwargsr"r#runnerfunchas_backend_args rwrapperz%pytest_fixture_setup..wrapperDs(CM(R(R% o  4&3F? #  o 6 6 7&!$'' 7!66tVDDDDDDDDDD((v66666  7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7sAA??BBr?r?)rErr fixturenamesargnames)r;r<rGrErFs @@rpytest_fixture_setuprKCs 7 7 7 7 7 7 ?D$:#6t#<#<: g2 2 2-1DDO%JO" :##'99#### 3 2:: : :r!T)tryfirst collectornameobjch|||rt|dr |jjn|}t |rl|d}t |dd}|std|Dr-tj d|dSdSdSdS)N hypothesisanyio pytestmarkc3,K|]}|jdkVdS)rRN)rN).0markers r z,pytest_pycollect_makeitem..as)NNV[G3NNNNNNr!r?) istestfunctionhasattrrQ inner_testrget_closest_markergetattranypytestmark usefixtures)rMrNrO inner_funcrW own_markerss rpytest_pycollect_makeitemrdZsT**>29#|2L2LUS^..RU z * * >11'::F!#|R88K >NN+NNNNN > ''88===== >> > > > >r! pyfuncitem bool | Nonecd fd }|jd}|rt|\t|jdrC|jjjj|jkr tr||jj_dSt|jrd|jfd|j j D}t5}| |j|dddn #1swxYwYd SdS) NrCr rr6ct5}||ddddS#1swxYwYdSN)r4run_test)rCrDr"r# original_funcs rrun_with_hypothesisz/pytest_pyfunc_call..run_with_hypothesisgs  o 6 6 3& OOM6 2 2 2 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3s 6::r?rQc"i|] }|| SrTrT)rVargfuncargss r z&pytest_pyfunc_call..zsWWWsXc]WWWr!T)rCr rr6) ror*r rZrOrQr[ __qualname__r _fixtureinforJr4rj) rerlrtestargsrDr"r#rorks @@@@rpytest_pyfunc_callrtess33333333!%%o66G(CG(L(L% o :>< 0 0 &N5@M)-@-MMM&}55O;NJN-84 z~ . . !*HWWWWj6M6VWWWHL/:: :f 999 : : : : : : : : : : : : : : :4 4sC>>DDmodule)scopeparamsc|jSri)param)r<s rr?r?s =r!r?c@t|tr|S|dS)NrrrrHs ranyio_backend_namer|s%-%% Qr!c@t|triS|dSr'r{rHs ranyio_backend_optionsr~s$-%%  Qr!)rrrr)r"rr#r$rr%)r5r rr6)r;r r<r rr6)rMr rNr rOr rr6)rer rrf)r<r rr )r?r rr)r?r rr$)% __future__rcollections.abcr contextlibrrinspectrrtypingr r r r r_r(_core._eventlooprrabcrr__annotations__rr0r r4r:rKhookimplrdrtfixturer?r|r~rTr!rrs-"""""""$$$$$$00000000;;;;;;;;)))))))))))) AAAAAAAA%)))))"& &&&&XXXX3333:::::.$>>> >$ :h'7'7'9'9:::;:          r!