+:jUddlmZddlmZddlmZmZddlmZm Z m Z m Z m Z ddl Z ddlZddlmZmZddlmZdad ed <dd Ze dd Zdd ZddZe j4dddZe j4dddZe j:eddZe j:ddZe j:ddZ y) ) annotations)contextmanager)isasyncgenfunctioniscoroutinefunction)AnyDict GeneratorTuplecastN)get_all_backends get_asynclib) TestRunnerzTestRunner | None_current_runnerct|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 rr TypeError)backends U/var/www/html/tokenscope/api/venv/lib/python3.12/site-packages/anyio/pytest_plugin.pyextract_backend_and_optionsrsq'3{ GU #G (9 gaj# &:gaj$+Gc4S>12G< < V WWc#Ktr tyt|}d}tjj dtjj |} |xsi}|j di|5}|a|dddda|r tjj|yy#1swY.xYw#da|r tjj|wwxYww)N)rrsniffiocurrent_async_library_cvargetsetrreset) backend_namebackend_optionsasynclibtokenrunners r get_runnerr)s L)H E))--d3;2266|D<)/R X 3? 3 v$OL    . . 4 4U ;       . . 4 4U ; s6ACB66B*=B6%C*B3/B66&CCc(|jddy)NmarkerszManyio: mark the (coroutine function) test to be run asynchronously via anyio.)addinivalue_line)configs rpytest_configurer.4s  $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)r1argskwargsr$r%r(funchas_backend_args rwrapperz%pytest_fixture_setup..wrapper=s}(CM(R% o &3F? #  o 6 7&!$'!66tVDDD((v66  7 7D 7 7s."A7!A+A)A+ A7)A++A40A7r1r1)r6rr fixturenamesargnames) fixturedefrequestr8r6r7s @@rpytest_fixture_setupr><sl 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 pytestmarkrc3:K|]}|jdk(yw)rBN)name).0markers r z,pytest_pycollect_makeitem..ZsNV[[G3Nsr1) istestfunctionhasattrrA inner_testrget_closest_markergetattranypytestmark usefixtures) collectorrEobj inner_funcrG own_markerss rpytest_pycollect_makeitemrVSsT*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)r5r(r$r% original_funcs rrun_with_hypothesisz/pytest_pyfunc_call..run_with_hypothesis`s2  o 6 3& OOM6 2 3 3 3s*3r1rAT)r5rreturnNone) funcargsr!rrJrSrArK __qualname__r _fixtureinfor;r)rZ) pyfuncitemr\rr_argtestargsr(r$r%r[s @@@rpytest_pyfunc_callre^s3!!%%o6G(CG(L% o :>>< 0&NN55@@M))-@-M-MM&}5;NJNN--8 z~~ .!**H6@6M6M6V6VWsXc]*WHWL/: :f 9 :  X :s& D(D--D6)paramsc|jSrY)param)r=s rr1r1|s ==rc0t|tr|S|dS)Nrrrr9s ranyio_backend_namerks-%Qrc0t|triS|dS)Nr rjr9s ranyio_backend_optionsrms-% Qr)robjectr]ztuple[str, dict[str, Any]])r$rr%dict[str, Any]r]z#Generator[TestRunner, object, None])r-rr]r^)r<rr=rr]r^)rRrrErrSrr]r^)rbrr]z bool | None)r=rr]r)r1rr]r)r1rr]ro)! __future__r contextlibrinspectrrtypingrrr r r rOr_core._eventloopr rabcrr__annotations__rr)r.r>hookimplrVrefixturer1rkrmrrrrys"%;44 <%)")X<<(6<(<<2:.$> >$ :')*+    r