o `^h@s^UddlmZddlZddlmZddlmZmZddlm Z m Z ddl m Z m Z ddlZddlZddlmZdd lmZmZdd lmZdd lmZejd krVdd lmZdaded<daded<dad;ddZ edd&d'Z#ej$d(d)d?d-d.Z%ej$d(d)d@d1d2Z&ej'd3ed4dAd5d6Z(ej'dBd7d8Z)ej'dCd9d:Z*dS)D) annotationsN)Iterator) ExitStackcontextmanager)isasyncgenfunctioniscoroutinefunction)Anycast)Exit)get_all_backendsget_async_backend)iterate_exceptions) TestRunner) )ExceptionGroupzTestRunner | None_current_runnerzExitStack | None _runner_stackbackendobjectreturntuple[str, dict[str, Any]]cCsft|tr |ifSt|tr/t|dkr/t|dtr/t|dtr/ttttttff|Std)Nrr z@anyio_backend must be either a string or tuple of (string, dict)) isinstancestrtuplelendictr r TypeError)rr Q/home/air/shanriGPT/back/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 )rr rrsniffiocurrent_async_library_cvargetsetcallbackreset enter_contextcreate_test_runner_runner_leasesclose)r#r$asynclibtokenr r r! get_runner#s2     r4configrNonecCs|dddS)NmarkerszManyio: mark the (coroutine function) test to be run asynchronously via anyio.)addinivalue_line)r5r r r!pytest_configureAsr9 fixturedefrequestcs`fdd}|jtstr,d|jvr*d|jv||_s.|jd7_dSdSdSdS)Nc?st|\}}r ||d<t||&}tr!||EdHn||VWddSWddS1s;wYdS)N anyio_backend)r"r4rrun_asyncgen_fixture run_fixture)r<argskwargsr#r$runnerfunchas_backend_argr r!wrapperJs  "z%pytest_fixture_setup..wrapperr<r<)rCrr fixturenamesargnames)r:r;rEr rBr!pytest_fixture_setupIs   rIT)tryfirst collectornameobjcCsv|||r5t|dr|jjn|}t|r7|d}t|dd}|s+tdd|Dr9tj d|dSdSdSdS)N hypothesisanyio pytestmarkr css|]}|jdkVqdS)rON)rL).0markerr r r! gsz,pytest_pycollect_makeitem..r<) istestfunctionhasattrrN inner_testrget_closest_markergetattranypytestmark usefixtures)rKrLrM inner_funcrR own_markersr r r!pytest_pycollect_makeitem`s   r_ pyfuncitem bool | Nonec sd fdd }|jd}|rt|\t|jdr3|jjjj|jkr1tr1||jj_dSt|jr|jfd d |j j D}t 2}z | |j|Wnt yt}zt|D] }t|tttfrn||qad}~wwWdd S1swYd SdS) Nr@rrr6cs<t}||WddS1swYdSN)r4run_test)r@rA)r#r$ original_funcr r!run_with_hypothesisms "z/pytest_pyfunc_call..run_with_hypothesisr<rNcsi|]}||qSr r )rQarg)funcargsr r! sz&pytest_pyfunc_call..T)r@rrr6)rgr*r"rUrMrNrV __qualname__r _fixtureinforHr4rcrrrr KeyboardInterrupt SystemExit)r`rertestargsrAexcgrpexcr )r#r$rgrdr!pytest_pyfunc_callks<            rpmodule)scopeparamscCs|jSrb)param)r;r r r!r<sr<cCst|tr|S|dS)NrrrrFr r r!anyio_backend_name rvcCst|triS|dSr'rurFr r r!anyio_backend_optionsrwrx)rrrr)r#rr$r%rr&)r5rrr6)r:rr;rrr6)rKrrLrrMrrr6)r`rrra)r;rrr)r<rrr)r<rrr%)+ __future__rsyscollections.abcr contextlibrrinspectrrtypingrr rZr(_pytest.outcomesr _core._eventloopr r _core._exceptionsrabcr version_infoexceptiongrouprr__annotations__rr0r"r4r9rIhookimplr_rpfixturer<rvrxr r r r!s@               $