:vj8UddlmZddlZddlmcmZddlZddl Z ddl Z ddl m Z m Z mZddlmZmZddlmZmZmZddlmZmZmZddlZddlmZmZddlmZdd l m!Z!d d l"m#Z#d d l$m%Z%m&Z&m'Z'm(Z(d d l)m*Z*erd dl+m,Z,e jZdkrddl.m/Z/erddl0m1Z2n ddl0m2Z2da4de5d<da6de5d<da7d0dZ8e d1dZ9d2dZ:d3dZ;d4dZ<ejzdd5dZ>ejzd d6d Z?d7d"Z@ejzdd8d#ZAejd$e#%d9d&ZCejd:d'ZDejd;d(ZEGd)d*ZFejd!+dd/ZJy#e3$r ddl0m1Z2YBwxYw)?) annotationsN)Callable GeneratorIterator) ExitStackcontextmanager)isasyncgenfunctioniscoroutinefunctionismethod) TYPE_CHECKINGAnycast)FuncFixtureInfo SubRequest)Exit)Scope)get_available_backends)current_async_libraryget_async_backendreset_current_async_libraryset_current_async_library)iterate_exceptions) TestRunner) )ExceptionGroup) CallSpec2)CallSpeczTestRunner | None_current_runnerzExitStack | None _runner_stackct|tr|ifSt|tr^t|dk(rPt|dtr=t|dtr*t ttttt ff|Std)Nrrz@anyio_backend must be either a string or tuple of (string, dict)) isinstancestrtuplelendictrr TypeError)backends d/workspace/moltex-experiments/.pixi/envs/default/lib/python3.12/site-packages/anyio/pytest_plugin.pyextract_backend_and_optionsr,/sq'3{ GU #G (9 gaj# &:gaj$+Gc4S>12G< < V WWc #Ktnt|}tat %t |}tj t||xsi}tj|j|atdz a ttdza tsd}t|u}|stjd|fdt|fdtjvstjtrtj tndtj |dz}dd|iz}t#tj$|dx}}tj'dxaayy#tdza tsd}t|u}|stjd|fdt|fdtjvstjtrtj tndtj |dz}dd|iz}t#tj$|dx}}tj'dxaawwxYww)Nr)is not)z%(py0)s is not %(py3)sr!)py0py3zassert %(py5)spy5)r rrr!rrcallbackr enter_contextcreate_test_runner_runner_leases @pytest_ar_call_reprcompare @py_builtinslocals_should_repr_global_name _safereprAssertionError_format_explanationclose) backend_namebackend_optionsasynclibtoken @py_assert2 @py_assert1 @py_format4 @py_format6s r+ get_runnerrH9s $\2! " *.l;E  " "#> F)/R'55  ' ' 8 aN3!(, ,=, , , ,= , , , , , ,= , , ,= , , , , , , , , , ,    !.2 2MO !(, ,=, , , ,= , , , , , ,= , , ,= , , , , , , , , , ,    !.2 2MOs A>I E' CI 'CII cx|jd}|jddd|jddddy) Nanyio anyio_modestrictz-AnyIO plugin mode (either "strict" or "auto"))defaulthelpz --anyio-modez 'auto' - All async test functions will be handled by AnyIO pytest plugin 'strict' - Disabling autoprocessing(useful when anyio tests need to coexist with other async test plugins) )rMdestrN)getgroupaddini addoption)parsergroups r+pytest_addoptionrUWsK OOG $E MM <  OO   r-cZ|j|ddk(xs|j|dk(S)N)rMauto) getoptiongetini)configmodes r+ _is_auto_moder\js3t,6W&--:MQW:Wr-c|jddt|drO|jjdr3t|dr&|j t j ddyyyy)NmarkerszManyio: mark the (coroutine function) test to be run asynchronously via anyio.rKasyncio asyncio_modezlAnyIO auto mode has been enabled together with pytest-asyncio auto mode. This may cause unexpected behavior.r)addinivalue_liner\ pluginmanager has_pluginissue_config_time_warningpytestPytestConfigWarning)rZs r+pytest_configurergpsu W fl+  + +I 6 &. 1((  & &<     2 7 ,r-T) hookwrapperc#Kdfd }|jts tr~d|jvrp||_|j}d|jvxs|xjdz c_d|jvxs|xjdz c_ d|_||_SdS#|_||_wxYww)N anyio_backendrequestc;K|jr[trPtjt|jur&jj |j}n}t |\}}r||d< r||d<t||5}|jr tdt|r|j||Ed{n|j||dddy7"#1swYyxYww)NrjrkzCannot schedule a coroutine in the test runner while another is already running; likely caused by request.getfixturevalue() on an async fixture.) instancer type__self____func____get__r,rH is_running RuntimeErrorr run_asyncgen_fixture run_fixture) rjrkkwargs local_funcr@rArunnerfunchas_backend_arghas_request_args r+wrapperz%pytest_fixture_setup..wrappers   T]]#tG,<,<'==..w/?/?@JJ(CM(R% o &3F? #  'F9   o 6&  ""V "*-!66z6JJJ((V<z,pytest_pycollect_makeitem..sHK&v{{g-Ksrj) istestfunctionhasattrr inner_testr r\rZget_closest_markergetattranyremark usefixtures) collectorrobj inner_funcanyio_auto_moder own_markerss r+pytest_pycollect_makeitemrsT*29#|2LS^^..RU z *+I,<,|j: } |j-| +||j||d zycc}w#t$rt!}YpwxYw) NrJrj _arg2scope)paramsindicesr_idlistmarks)funcargsrr arg2scopeidlistr)r initialnames names_closurename2fixturedefs[])rcallspeccallobj fixtureinfokeywords originalnamer) reversedlist enumerateitemsr$reFunctionr functionrr dataclassesfieldsrrr)setrrModule _fixtureinforappendrrrr from_parentparentrrr) riitem new_itemsf cs_fields param_indexr*rfinew_names_closurenew_fixtureinfonew_items r+pytest_collection_finishrsD7==!9:;4 tV__ -#DMM2''0<t'8'88I "-8-?-?-IJ-IQVV-I J)22H2J(K$ W9,' /9!0+ >$3U\\#B!(   H (!# /9!0+ >#2ELL"A 'y  H&&$()9)9$:!"*;;%,,_="1[[!#"3%'%8%8 # "??66KK --.ay:% HH /!]]!%!2!27  *O)LR(1GMM!a!e $m<K "E  "s$HH 2H HH%$H%c  d fd }|jjd}|rt|\ t|jdr`|jj j j|jk7r&t r||jj _yt|jrg|j}|jjDcic]}||| }}t 5} |j|j| dddyycc}w#t$r4}t|D] }t|t t"t$fs||d}~wwxYw#1swYyxYw)Nclt5}|j|dddy#1swYyxYwN)rHrun_test)rvrxr@rA original_funcs r+run_with_hypothesisz/pytest_pyfunc_call..run_with_hypothesiss)  o 6& OOM6 27 6 6s*3rjrT)rvr rNone)rgetr,rrrr __qualname__r rrrHrrrr$rKeyboardInterrupt SystemExit) pyfuncitemrr*rargtestargsrxexcgrpexcr@rArs @@@r+pytest_pyfunc_callr sJ3!!%%o6G(CG(L% o :>>< 0&NN55@@M))-@-M-MM&}5;NJNN--8 z~~ .!**H6@6M6M6V6VW6VsXc]*6VHWL/:fOOJNNH=; X&1&9%cD2CZ+PQ"%61 : ;s6' D+E0D00 E-9)E(#E((E--E00E9module)scoperc|jSr)paramr~s r+rjrj1s ==r-c0t|tr|S|dS)Nrr$r%r}s r+anyio_backend_namer6s-%Qr-c0t|triS|dS)Nrrr}s r+anyio_backend_optionsr>s-% Qr-c4eZdZdZddZeddZdd dZy) FreePortFactoryaO Manages port generation based on specified socket kind, ensuring no duplicate ports are generated. This class provides functionality for generating available free ports on the system. It is initialized with a specific socket kind and can generate ports for given address families while avoiding reuse of previously generated ports. Users should not instantiate this class directly, but use the ``free_tcp_port_factory`` and ``free_udp_port_factory`` fixtures instead. For simple uses cases, ``free_tcp_port`` and ``free_udp_port`` can be used instead. c>||_tt|_yr)_kindrint _generated)selfkinds r+__init__zFreePortFactory.__init__Ts c(*r-c|jS)z The type of socket connection (e.g., :data:`~socket.SOCK_STREAM` or :data:`~socket.SOCK_DGRAM`) used to bind for checking port availability )r)rs r+rzFreePortFactory.kindXszzr-NcJ||g}n@tjg}tjr|jtj d}t 5}|D]r}|j tj||j}|tjk(rdnd} |j||f|r`|jd}t||jvr&|jj||cdddSddd#t$rYwxYw#1swYxYw)z Return an unbound port for the given address family. :param family: if omitted, both IPv4 and IPv6 addresses will be tried :return: a port number Nrz::1z 127.0.0.1r) socketAF_INEThas_ipv6rAF_INET6rr4rbindOSError getsocknameradd)rfamilyfamiliesportstackfamsockaddrs r+__call__zFreePortFactory.__call__as  xH'H0D#C ..v}}S$**/MND$'6??$:5 D 4,/ #//1!4$4??2++D1## s7A D!D 4D7?D DDDDD")rsocket.SocketKindrr)rrr)rzsocket.AddressFamily | Nonerr)__name__ __module__r__doc__rpropertyrrrr-r+rrFs% %$r-r)rc4ttjSr)rr SOCK_STREAMrr-r+free_tcp_port_factoryrs 6-- ..r-c4ttjSr)rr SOCK_DGRAMrr-r+free_udp_port_factoryr s 6,, --r-c|Srr)rs r+ free_tcp_portr  ""r-c|Srr)r s r+ free_udp_portrr r-)r*objectrztuple[str, dict[str, Any]])r@r%rAdict[str, Any]rzIterator[TestRunner])rSz pytest.Parserrr)rZ pytest.Configr[r%rbool)rZrrr)rr rkr rzGenerator[Any])rzpytest.Module | pytest.Classrr%rrrr)rzpytest.Sessionrr)rr rz bool | None)rkr rr )rjr rr%)rjr rr)rr)rCallable[[], int]rr)r rrr)K __future__rbuiltinsr9_pytest.assertion.rewrite assertionrewriter7rrsyscollections.abcrrr contextlibrrinspectr r r typingr r rre_pytest.fixturesrr_pytest.outcomesr _pytest.scoperr_core._eventlooprrrr_core._exceptionsrabcr version_infoexceptiongroupr_pytest.pythonrr ImportErrorr __annotations__r!r6r,rHrUr\rghookimplrrrrfixturerjrrrrr r rrr-r+r,s:" 990EE++ 8!$ 2g-49 ,&*")"& &X33(6333:&  &T"9#9x$>+>36>=C> > >"71t$! !Hh'='?@A    :$:$zi /!/i .!.####Y 9889sG G'&G'