+
     Bi?                         Rt ^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^RIHt ^RIH	t	 ^RIH
t
 ^RIHt ^RIHt  ! R R]P                  4      t ! R	 R 4      tR
RRR/R ltR tR# )RunnerN)
coroutines)events)
exceptions)tasks)	constantsc                   "    ] tR t^tRtRtRtRtR# )_Statecreatedinitializedclosed N)__name__
__module____qualname____firstlineno__CREATEDINITIALIZEDCLOSED__static_attributes__r       &/usr/lib/python3.14/asyncio/runners.pyr	   r	      s    GKFr   r	   c                   d   a  ] tR t^t o RRRR/R ltR tR tR tR tR	R/R
 lt	R t
R tRtV tR# )r   debugNloop_factoryc                   \         P                  V n        Wn        W n        R V n        R V n        ^ V n        RV n        R # )NF)	r	   r   _state_debug_loop_factory_loop_context_interrupt_count_set_event_loop)selfr   r   s   &$$r   __init__Runner.__init__1   s6    nn)
 !$r   c                &    V P                  4        V # N)
_lazy_initr#   s   &r   	__enter__Runner.__enter__:   s    r   c                &    V P                  4        R # r'   )close)r#   exc_typeexc_valexc_tbs   &&&&r   __exit__Runner.__exit__>   s    

r   c                j   V P                   \        P                  Jd   R #  V P                  p\	        V4       VP                  VP                  4       4       VP                  VP                  \        P                  4      4       V P                  '       d   \        P                  ! R 4       VP                  4        R V n        \        P                  V n         R #   T P                  '       d   \        P                  ! R 4       XP                  4        R T n        \        P                  T n         i ; ir'   )r   r	   r   r   _cancel_all_tasksrun_until_completeshutdown_asyncgensshutdown_default_executorr   THREAD_JOIN_TIMEOUTr"   r   set_event_loopr-   r   )r#   loops   & r   r-   Runner.closeA   s    ;;f000	(::Dd###D$;$;$=>##..y/L/LMO ###%%d+JJLDJ --DK	 ###%%d+JJLDJ --DKs   A$C AD2c                :    V P                  4        V P                  # r'   )r(   r   r)   s   &r   get_loopRunner.get_loopR   s    zzr   contextc               T   \         P                  ! 4       e   \        R4      hV P                  4        \        P
                  ! V4      '       g4   \        P                  ! V4      '       d   R pV! V4      pM\        R4      hVf   V P                  pV P                  P                  WR7      p\        P                  ! 4       \        P                  ! 4       J d   \        P                   ! \        P"                  4      \        P$                  J dJ   \&        P(                  ! V P*                  VR7      p \        P                  ! \        P"                  V4       MR p^ V n         V P                  P1                  V4      Ve^   \        P                   ! \        P"                  4      VJ d5   \        P                  ! \        P"                  \        P$                  4       # # #   \,         d    R p Li ; i  \2        P4                   d;    T P.                  ^ 8  d(   \7        TRR 4      pTe   T! 4       ^ 8X  d   \9        4       hh i ; i  Te^   \        P                   ! \        P"                  4      TJ d5   \        P                  ! \        P"                  \        P$                  4       i i i ; i)Nz7Runner.run() cannot be called from a running event loopc                 "   "   V G R j  xL
 #  L5ir'   r   )	awaitables   &r   _wrap_awaitable#Runner.run.<locals>._wrap_awaitableb   s     !*?*?s   z:An asyncio.Future, a coroutine or an awaitable is required)r?   )	main_taskuncancel)r   _get_running_loopRuntimeErrorr(   r   iscoroutineinspectisawaitable	TypeErrorr    r   create_task	threadingcurrent_threadmain_threadsignal	getsignalSIGINTdefault_int_handler	functoolspartial
_on_sigint
ValueErrorr!   r5   r   CancelledErrorgetattrKeyboardInterrupt)r#   coror?   rC   tasksigint_handlerrF   s   &&$    r   run
Runner.runW   s   ##%1IK K 	%%d++""4((+ 't, !8 9 9 ?mmGzz%%d%<$$&)*?*?*AA  /63M3MM&..t$ON&fmm^< "N !	I::006 *$$V]]3~EfmmV-G-GH F +%  & "&	& (( 	$$q("4T:'HJ!O+--	 *$$V]]3~EfmmV-G-GH F +s,   3%G #G2 G/.G/2AII A#J'c                J   V P                   \        P                  J d   \        R 4      hV P                   \        P                  J d   R# V P
                  fU   \        P                  ! 4       V n        V P                  '       g(   \        P                  ! V P                  4       RV n	        MV P                  4       V n        V P                  e&   V P                  P                  V P                  4       \        P                  ! 4       V n        \        P                  V n         R# )zRunner is closedNT)r   r	   r   rH   r   r   r   new_event_loopr   r"   r9   r   	set_debugcontextvarscopy_contextr    r)   s   &r   r(   Runner._lazy_init   s    ;;&--'122;;&,,,%..0DJ''' %%djj1'+$++-DJ;;"JJ  -#002((r   c                    V ;P                   ^,          un         V P                   ^8X  dE   VP                  4       '       g/   VP                  4        V P                  P	                  R 4       R# \        4       h)   c                      R # r'   r   r   r   r   <lambda>#Runner._on_sigint.<locals>.<lambda>   s    Dr   N)r!   donecancelr   call_soon_threadsafer[   )r#   signumframerE   s   &&&&r   rW   Runner._on_sigint   sW    "  A%inn.>.>JJ++L9!!r   )r    r   r!   r   r   r"   r   )r   r   r   r   r$   r*   r1   r-   r=   r_   r(   rW   r   __classdictcell__)__classdict__s   @r   r   r      sJ     8% %4 %("
3I4 3Ij)&" "r   r   r   c                    \         P                  ! 4       e   \        R4      h\        WR7      ;_uu_ 4       pVP	                  V 4      uuR R R 4       #   + '       g   i     R # ; i)Nz8asyncio.run() cannot be called from a running event loop)r   r   )r   rG   rH   r   r_   )mainr   r   runners   &$$ r   r_   r_      sO    : !-FH 	H 
e	7	76zz$ 
8	7	7	7s   AA$	c           	      v   \         P                  ! V 4      pV'       g   R # V F  pVP                  4        K  	  V P                  \         P                  ! VRR/ 4       V FT  pVP                  4       '       d   K  VP                  4       f   K/  V P                  RRRVP                  4       RV/4       KV  	  R # )Nreturn_exceptionsTmessagez1unhandled exception during asyncio.run() shutdown	exceptionr]   )r   	all_tasksrm   r5   gather	cancelledrz   call_exception_handler)r:   	to_cancelr]   s   &  r   r4   r4      s    %I  	ELL)LtLM>>>>'''NT^^-) 	 r   )r   r_   )__all__rd   enumrU   rJ   rN   rQ    r   r   r   r   r   Enumr	   r   r_   r4   r   r   r   <module>r      sa   
           TYY Q" Q"h# t # $ # Lr   