o tf @s0UddlmZddlmZddlmZmZddlmZm Z ddl m Z m Z m Z mZddlZddlZddlmZmZdd lmZdad ed <dad ed <dad7ddZed8ddZd9ddZd:d"d#Zejd$d%d;d)d*Zejd$d%dd3d4Z#ej!d?d5d6Z$dS)@) annotations)Iterator) ExitStackcontextmanager)isasyncgenfunctioniscoroutinefunction)AnyDictTuplecastN)get_all_backendsget_async_backend) TestRunnerzTestRunner | None_current_runnerzExitStack | None _runner_stackbackendobjectreturntuple[str, dict[str, Any]]cCsft|tr |ifSt|tr/t|dkr/t|dtr/t|dtr/ttttttff|St d)Nrr z@anyio_backend must be either a string or tuple of (string, dict)) isinstancestrtuplelendictr r r r TypeError)rr\/var/www/html/software/conda/envs/catlas/lib/python3.10/site-packages/anyio/pytest_plugin.pyextract_backend_and_optionss r backend_namerbackend_optionsdict[str, Any]Iterator[TestRunner]ccstdur.t|}tatjddur"tj|}ttjj ||p%i}t | |at d7a ztVWt d8a t sMtdusCJt daadSdSt d8a t sctdus[Jt daawNr )rrrrsniffioZcurrent_async_library_cvargetsetcallbackreset enter_contextZcreate_test_runner_runner_leasesclose)r r!Zasynclibtokenrrr get_runners2     r.configrNonecCs|dddS)NmarkerszManyio: mark the (coroutine function) test to be run asynchronously via anyio.)Zaddinivalue_line)r/rrrpytest_configure;sr2 fixturedefrequestcs`fdd}|jtstr,d|jvr*d|jv||_s.|jd7_dSdSdSdS)Nc?st|\}}r ||d<t||&}tr!||EdHn||VWddSWddS1s;wYdS)N anyio_backend)rr.rZrun_asyncgen_fixtureZ run_fixture)r5argskwargsr r!runnerfuncZhas_backend_argrrwrapperDs  "z%pytest_fixture_setup..wrapperr5r5)r:rrZ fixturenamesargnames)r3r4r;rr9rpytest_fixture_setupCs   r>T)Ztryfirst collectornameobjcCsv|||r5t|dr|jjn|}t|r7|d}t|dd}|s+tdd|Dr9tj d|dSdSdSdS)N hypothesisanyioZ pytestmarkrcss|]}|jdkVqdS)rCN)r@).0markerrrr asz,pytest_pycollect_makeitem..r5) ZistestfunctionhasattrrB inner_testrZget_closest_markergetattranypytestmarkZ usefixtures)r?r@rAZ inner_funcrEZ own_markersrrrpytest_pycollect_makeitemZs   rM pyfuncitem bool | Nonecsd fdd }|jd}|ret|\t|jdr3|jjjj|jkr1tr1||jj_dSt|jre|jfd d |j j D}t }| |j|Wdd S1s^wYd SdS) Nr7rrr0cs<t}||WddS1swYdSN)r.run_test)r7r8)r r! original_funcrrrun_with_hypothesisgs "z/pytest_pyfunc_call..run_with_hypothesisr5rBcsi|]}||qSrr)rDarg)funcargsrr zsz&pytest_pyfunc_call..T)r7rrr0) rUr&rrGrArBrH __qualname__rZ _fixtureinfor=r.rQ)rNrSrZtestargsr8r)r r!rUrRrpytest_pyfunc_calles(         rXmodule)scopeparamscCs|jSrP)param)r4rrrr5sr5cCst|tr|S|dS)Nrrrr<rrranyio_backend_name r^cCst|triS|dSr$r]r<rrranyio_backend_optionsr_r`)rrrr)r rr!r"rr#)r/rrr0)r3rr4rrr0)r?rr@rrArrr0)rNrrrO)r4rrr)r5rrr)r5rrr")% __future__rcollections.abcr contextlibrrinspectrrtypingrr r r rKr%Z_core._eventloopr rabcrr__annotations__rr+rr.r2r>ZhookimplrMrXZfixturer5r^r`rrrrs6