o #6d@sUddlmZddlmZddlmZmZddlmZm Z m Z m Z m Z ddl Z ddlZddlmZmZddlmZdad ed <d3ddZed4ddZd5ddZd6dd Ze jd!d"d7d&d'Ze jd!d"d8d*d+Ze jed,d9d-d.Ze jd:d/d0Ze jd;d1d2Z dS)<) annotations)contextmanager)isasyncgenfunctioniscoroutinefunction)AnyDict GeneratorTuplecastN)get_all_backends get_asynclib) TestRunnerzTestRunner | None_current_runnerbackendobjectreturntuple[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 rr TypeError)rrjC:\Users\jesus\OneDrive\Desktop\erpjis_fastapi\backend\jisbackend\Lib\site-packages\anyio/pytest_plugin.pyextract_backend_and_optionss r backend_namerbackend_optionsdict[str, Any]#Generator[TestRunner, object, None]c cstrtVdSt|}d}tjddurtj|}z0|p i}|jdi| }|a|VWdn1s9wYWda|rKtj|dSdSda|rXtj|ww)Nr)rr sniffioZcurrent_async_library_cvargetsetrreset)rrZasynclibtokenrunnerrrr get_runners. r(configrNonecCs|dddS)NmarkerszManyio: mark the (coroutine function) test to be run asynchronously via anyio.)Zaddinivalue_line)r)rrrpytest_configure4sr, 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)r/argskwargsrrr'funcZhas_backend_argrrwrapper=s  "z%pytest_fixture_setup..wrapperr/r/)r3rrZ fixturenamesargnames)r-r.r4rr2rpytest_fixture_setup<s   r7T)Ztryfirst collectornameobjcCsv|||r5t|dr|jjn|}t|r7|d}t|dd}|s+tdd|Dr9tj d|dSdSdSdS)N hypothesisanyioZ pytestmarkrcss|]}|jdkVqdS)r<N)r9).0markerrrr Zsz,pytest_pycollect_makeitem..r/) Zistestfunctionhasattrr; inner_testrZget_closest_markergetattranypytestmarkZ usefixtures)r8r9r:Z inner_funcr>Z own_markersrrrpytest_pycollect_makeitemSs   rF pyfuncitem bool | Nonecsd fdd }|jd}|ret|\t|jdr3|jjjj|jkr1tr1||jj_dSt|jre|jfd d |j j D}t }| |j|Wdd S1s^wYd SdS) Nr1rrr*cs<t}||WddS1swYdSN)r(run_test)r1r')rr original_funcrrrun_with_hypothesis`s "z/pytest_pyfunc_call..run_with_hypothesisr/r;csi|]}||qSrr)r=arg)funcargsrr ssz&pytest_pyfunc_call..T)r1rrr*) rNr#rr@r:r;rA __qualname__rZ _fixtureinfor6r(rJ)rGrLrZtestargsr'r)rrrNrKrpytest_pyfunc_call^s(         rQ)paramscCs|jSrI)param)r.rrrr/|sr/cCst|tr|S|dS)Nrrrr5rrranyio_backend_name rUcCst|triS|dS)Nr rTr5rrranyio_backend_optionsrVrW)rrrr)rrrr rr!)r)rrr*)r-rr.rrr*)r8rr9rr:rrr*)rGrrrH)r.rrr)r/rrr)r/rrr )! __future__r contextlibrinspectrrtypingrrrr r rDr"Z_core._eventloopr r abcrr__annotations__rr(r,r7ZhookimplrFrQZfixturer/rUrWrrrrs0