*jB S r SSKrSSKrSSKrSSKrSSKrSSKJr SSKJr SSKJ r SSKJ
r
SSKJ r " S S
\R 5 r
" S S 5 rSSS
.S jrS rg))Runnerrun N )
coroutines)events)
exceptions)tasks) constantsc \ rS rSrSrSrSrSrg)_State created initializedclosed N)__name__
__module__ __qualname____firstlineno__CREATED INITIALIZEDCLOSED__static_attributes__r 6/opt/alt/python313/lib64/python3.13/asyncio/runners.pyr r s G K
Fr r c V \ rS rSrSSS.S jrS rS rS rS rSS .S
jr S r
S r S
r g)r Ndebug loop_factoryc ~ [ R U l Xl X l S U l S U l SU l SU l g )Nr F) 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 & U R 5 U $ N)
_lazy_initr) s r __enter__Runner.__enter__: s r c $ U R 5 g r- )close)r) exc_typeexc_valexc_tbs r __exit__Runner.__exit__> s
r c ` U R [ R La g U R n[ U5 UR UR
5 5 UR UR [ R 5 5 U R ( a [ R " S 5 UR 5 S U l [ R U l g ! U R ( a [ R " S 5 WR 5 S U l [ R U l f = fr- )r" r r r% _cancel_all_tasksrun_until_completeshutdown_asyncgensshutdown_default_executorr
THREAD_JOIN_TIMEOUTr( r set_event_loopr3 r )r) loops r r3 Runner.closeA s ;;f 0 0 0 (::D d # # #D$;$;$= > # #..y/L/LM
O ##%%d+ JJL DJ --DK ##%%d+ JJL DJ --DKs
A$C AD-c : U R 5 U R $ r- )r. r% r/ s r get_loopRunner.get_loopR s zzr contextc [ R " U5 ( d [ SR U5 5 e[ R
" 5 b [
S5 eU R 5 Uc U R nU R R XS9n[ R " 5 [ R " 5 L a{ [ R " [ R 5 [ R" L aF [$ R& " U R( US9n [ R " [ R U5 OS nSU l U R R- U5 Ub\ [ R " [ R 5 UL a4 [ R " [ R [ R" 5 $ $ $ ! [ a S n Nf = f! [. R0 a7 U R* S: a% [3 USS 5 nUb U" 5 S:X a
[5 5 ee f = f! Ub\ [ R " [ R 5 UL a4 [ R " [ R [ R" 5 f f f = f)Nz"a coroutine was expected, got {!r}z7Runner.run() cannot be called from a running event looprE ) main_taskr uncancel)r iscoroutine
ValueErrorformatr _get_running_loop RuntimeErrorr. r& r% create_task threadingcurrent_thread main_threadsignal getsignalSIGINTdefault_int_handler functoolspartial
_on_sigintr' r; r CancelledErrorgetattrKeyboardInterrupt)r) cororF tasksigint_handlerrI s r r
Runner.runW s %%d++ A H H NO O # # % 1 IK
K
?mmGzz%%d%< $ $ &)*?*?*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, %F9 ?G 9 GG A HH A!I:c < U R [ R L a [ S5 eU R [ R L a g U R
cS [ R " 5 U l U R ( d' [ R " U R 5 SU l OU R 5 U l U R b% U R R U R 5 [ R " 5 U l [ R U l g )NzRunner is closedT)r" r r rN r r$ r new_event_loopr% r( r? r# set_debug contextvars copy_contextr& r/ s r r. Runner._lazy_init s ;;&-- ' 12 2 ;;&,, , % ..0DJ'' %%djj1'+$ ++-DJ ;; " JJ -#002
(( r c U =R S-
sl U R S:X aB UR 5 ( d- UR 5 U R R S 5 g [ 5 e)Nr c g r- r r r r #Runner._on_sigint.. s Dr )r' donecancelr% call_soon_threadsafer\ )r) signumframerH s r rY Runner._on_sigint sW " A %inn.>.> JJ + +L 9 !!r )r& r# r' r% r$ r( r" )
r r r r r* r0 r7 r3 rC r r. rY r r r r r r s8 : !%4 %("
$( +IZ)&"r r r c [ R " 5 b [ S5 e[ XS9 nUR U 5 sS S S 5 $ ! , ( d f g = f)Nz8asyncio.run() cannot be called from a running event loopr )r rM rN r r )mainr r runners r r r sI : !- FH H
e 76zz$
8 7 7s A
Ac h [ R " U 5 nU( d g U H nUR 5 M U R [ R " USS065 U HP nUR 5 ( a M UR
5 c M- U R SUR
5 US.5 MR g )Nreturn_exceptionsTz1unhandled exception during asyncio.run() shutdown)message exceptionr^ )r all_tasksrl r; gather cancelledrw call_exception_handler)r@ to_cancelr^ s r r: r: s %I
ELL) Lt LM >> >> ' ' 'N !^^ - )
r )__all__rd enumrW rP rS r r r r r
Enumr r r r: r r r r sW
TYY J" J"Z $ # Lr