U e @snUddlmZddlmZddlmZmZddlmZm Z ddl m Z m Z m Z mZddlZddlZddlmZmZdd lmZdad ed <dad ed <dadddddZeddddddZdddddZdddddd Zejd!d"ddddd#d$d%Zejd!d"dd&d'd(d)Z ej!d*ed+ddd,d-d.Z"ej!ddd/d0d1Z#ej!ddd/d2d3Z$dS)4) annotations)Iterator) ExitStackcontextmanager)isasyncgenfunctioniscoroutinefunction)AnyDictTuplecastN)get_all_backendsget_async_backend) TestRunnerzTestRunner | None_current_runnerzExitStack | None _runner_stackobjectztuple[str, dict[str, Any]])backendreturncCsjt|tr|ifSt|tr^t|dkr^t|dtr^t|dtr^ttttttff|St ddS)Nrr z@anyio_backend must be either a string or tuple of (string, dict)) isinstancestrtuplelendictr r r r TypeError)rr7/tmp/pip-unpacked-wheel-7mhetrzx/anyio/pytest_plugin.pyextract_backend_and_optionss  rrzdict[str, Any]zIterator[TestRunner]) backend_namebackend_optionsrccstdkrZt|}tatjddkrBtj|}ttjj ||pHi}t | |at d7a z tVW5t d8a t stdk st tdaaXdSNr )rrrrsniffioZcurrent_async_library_cvargetsetcallbackreset enter_contextZcreate_test_runner_runner_leasesAssertionErrorclose)rr Zasynclibtokenrrr get_runners$   r,rNone)configrcCs|dddS)NmarkerszManyio: mark the (coroutine function) test to be run asynchronously via anyio.)Zaddinivalue_line)r.rrrpytest_configure;sr0) fixturedefrequestrcsTfdd}|jts$trPd|jkrPd|jk||_sP|jd7_dS)Nc ?s\t|\}}r||d<t||0}tr@||EdHn||VW5QRXdS)N anyio_backend)rr,rZrun_asyncgen_fixtureZ run_fixture)r3argskwargsrr runnerfuncZhas_backend_argrrwrapperDs  z%pytest_fixture_setup..wrapperr3r3)r8rrZ fixturenamesargnames)r1r2r9rr7rpytest_fixture_setupCs   r<T)Ztryfirst) collectornameobjrcCsj|||rft|dr|jjn|}t|rf|d}t|dd}|sVtdd|Drftj d|dS)N hypothesisanyioZ pytestmarkrcss|]}|jdkVqdS)rAN)r>).0markerrrr asz,pytest_pycollect_makeitem..r3) Zistestfunctionhasattrr@ inner_testrZget_closest_markergetattranypytestmarkZ usefixtures)r=r>r?Z inner_funcrCZ own_markersrrrpytest_pycollect_makeitemZs   rKz bool | None) pyfuncitemrc sdddfdd }|jd}|rt|\t|jdrl|jjjj|jkrhtrh||jj_dSt|jr|jfdd |j j D}t }| |j|W5QRXd SdS) Nrr-)r5rc s&t}||W5QRXdSN)r,run_test)r5r6)rr original_funcrrrun_with_hypothesisgs z/pytest_pyfunc_call..run_with_hypothesisr3r@csi|]}||qSrr)rBarg)funcargsrr zsz&pytest_pyfunc_call..T) rRr#rrEr?r@rF __qualname__rZ _fixtureinfor;r,rN)rLrPrZtestargsr6r)rr rRrOrpytest_pyfunc_calles"        rUmodule)Zscopeparams)r2rcCs|jSrM)param)r2rrrr3sr3)r3rcCst|tr|S|dSdS)Nrrrr:rrranyio_backend_names rZcCst|triS|dSdSr!rYr:rrranyio_backend_optionss r[)% __future__rcollections.abcr contextlibrrinspectrrtypingrr r r rIr"Z_core._eventloopr rabcrr__annotations__rr(rr,r0r<ZhookimplrKrUZfixturer3rZr[rrrrs6