o f @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)rrK/var/www/NoticeGen/venv/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 )rrrrsniffiocurrent_async_library_cvargetsetcallbackreset enter_contextcreate_test_runner_runner_leasesclose)r r!asynclibtokenrrr get_runners2     r1configrNonecCs|dddS)NmarkerszManyio: mark the (coroutine function) test to be run asynchronously via anyio.)addinivalue_line)r2rrrpytest_configure;sr6 fixturedefrequestcs`fdd}|jtstr,d|jvr*d|jv||_s.|jd7_dSdSdSdS)Nc?st|\}}r ||d<t||&}tr!||EdHn||VWddSWddS1s;wYdS)N anyio_backend)rr1rrun_asyncgen_fixture run_fixture)r9argskwargsr r!runnerfunchas_backend_argrrwrapperDs  "z%pytest_fixture_setup..wrapperr9r9)r@rr fixturenamesargnames)r7r8rBrr?rpytest_fixture_setupCs   rFT)tryfirst collectornameobjcCsv|||r5t|dr|jjn|}t|r7|d}t|dd}|s+tdd|Dr9tj d|dSdSdSdS)N hypothesisanyio pytestmarkrcss|]}|jdkVqdS)rLN)rI).0markerrrr asz,pytest_pycollect_makeitem..r9) istestfunctionhasattrrK inner_testrget_closest_markergetattranypytestmark usefixtures)rHrIrJ inner_funcrO own_markersrrrpytest_pycollect_makeitemZs   r\ pyfuncitem bool | Nonecsd fdd }|jd}|ret|\t|jdr3|jjjj|jkr1tr1||jj_dSt|jre|jfd d |j j D}t }| |j|Wdd S1s^wYd SdS) Nr=rrr3cs<t}||WddS1swYdSN)r1run_test)r=r>)r r! original_funcrrrun_with_hypothesisgs "z/pytest_pyfunc_call..run_with_hypothesisr9rKcsi|]}||qSrr)rNarg)funcargsrr zsz&pytest_pyfunc_call..T)r=rrr3) rdr'rrRrJrKrS __qualname__r _fixtureinforEr1r`)r]rbrtestargsr>r)r r!rdrarpytest_pyfunc_calles(         rimodule)scopeparamscCs|jSr_)param)r8rrrr9sr9cCst|tr|S|dS)NrrrrCrrranyio_backend_name rocCst|triS|dSr$rnrCrrranyio_backend_optionsrprq)rrrr)r rr!r"rr#)r2rrr3)r7rr8rrr3)rHrrIrrJrrr3)r]rrr^)r8rrr)r9rrr)r9rrr")% __future__rcollections.abcr contextlibrrinspectrrtypingrr r r rWr%_core._eventloopr rabcrr__annotations__rr-rr1r6rFhookimplr\rifixturer9rorqrrrrs6