֦i> d Z ddlZddlZddlZddlZddlZddlmZ ddlmZ ddlm Z ddlm
Z
ddlm Z G d d
ej Z
G d d Zddd
dZd Zy))Runnerrun N )
coroutines)events)
exceptions)tasks) constantsc e Zd ZdZdZdZy)_Statecreated initializedclosedN)__name__
__module__ __qualname__CREATED INITIALIZEDCLOSED (/usr/lib64/python3.12/asyncio/runners.pyr r s G K
Fr r c L e Zd Z ddddZd Zd Zd Zd Zddd Zd
Z d Z
y) r Ndebug loop_factoryc t j | _ || _ || _ d | _ d | _ d| _ d| _ y )Nr F) r r _state_debug
_loop_factory_loop_context_interrupt_count_set_event_loop)selfr r s r __init__zRunner.__init__0 s: nn )
! $ r c & | j | S N)
_lazy_initr% s r __enter__zRunner.__enter__9 s r c $ | j y r( )close)r% exc_typeexc_valexc_tbs r __exit__zRunner.__exit__= s
r c H | j t j ury | j }t | |j |j
|j |j t j | j rt j d |j d | _ t j | _ y # | j rt j d j d | _ t j | _ w xY wr( )r r r r! _cancel_all_tasksrun_until_completeshutdown_asyncgensshutdown_default_executorr
THREAD_JOIN_TIMEOUTr$ r set_event_loopr- r )r% loops r r- z Runner.close@ s , ;;f 0 0 0 (::D d # # #D$;$;$= > # #..y/L/LM
O ##%%d+ JJL DJ --DK ##%%d+ JJL DJ --DKs
A$C AD!c < | j | j S r( )r) r! r* s r get_loopzRunner.get_loopQ s ) zzr contextc t j | st dj | t j
t
d | j | | j }| j j || }t j t j u rzt j t j t j" u rGt% j& | j( | } t j t j | nd }d| _ | j j- | |Yt j t j |u r3t j t j t j" S S S # t $ r d }Y w xY w# t. j0 $ r4 | j* dkD r#t3 |dd }| | dk( r
t5 w xY w# |Yt j t j |u r3t j t j t j" w w w xY w)Nz"a coroutine was expected, got {!r}z7Runner.run() cannot be called from a running event loopr< ) main_taskr uncancel)r iscoroutine
ValueErrorformatr _get_running_loop RuntimeErrorr) r" r! create_task threadingcurrent_thread main_threadsignal getsignalSIGINTdefault_int_handler functoolspartial
_on_sigintr# r4 r CancelledErrorgetattrKeyboardInterrupt)r% coror= tasksigint_handlerr@ s r r z
Runner.runV s =%%d+ A H H NO O # # % 1 IK
K
?mmGzz%%dG%< $ $ &)*?*?*A A /63M3MM & . .t$ ON
&
fmm^< "N ! I::006 *$$V]]3~E
fmmV-G-GH F +%
& "&
& (( $$q("4T:'HJ!O+-- *$$V]]3~E
fmmV-G-GH F +s, $F- 7F> - F;:F;>AHH A I%c $ | j t j u r t d | j t j u ry | j
Lt
j | _ | j sz#Runner._on_sigint.. s Dr )r# donecancelr! call_soon_threadsaferS )r% signumframer? s r rP zRunner._on_sigint sT " A %inn.> JJ + +L 9 !!r ) r r r r& r+ r1 r- r; r r) rP r r r r r s= 6 !%4 %("
$( +IZ)&"r r r c t j t d t || 5 }|j | cd d d S # 1 sw Y y xY w)Nz8asyncio.run() cannot be called from a running event loopr )r rD rE r r )mainr r runners r r r sP 8 !- FH H
e, 76zz$
8 7 7s A Ac B t j | }|sy |D ] }|j | j t j |ddi |D ]G }|j r|j
%| j d|j
|d I y )Nreturn_exceptionsTz1unhandled exception during asyncio.run() shutdown)message exceptionrU )r all_tasksr` r4 gather cancelledrj call_exception_handler)r9 to_cancelrU s r r3 r3 s %I
ELL) Lt LM >> >> ' ' 'N !^^ - )
r )__all__rZ enumrN rG rJ r r r r r
Enumr r r r3 r r r rt sW
TYY I" I"X $ # Lr