cjW% @ d Z ddlmZ ddlmZ ddlmZ G d d Zy)) TaskGroup )events)
exceptions)tasksc V e Zd Z d Zd Zd Zd Zd ZddddZd e d
e
fd Z d Z d
Z
y)r c d| _ d| _ d| _ d | _ d | _ d| _ t
| _ g | _ d | _ d | _
y )NF) _entered_exiting _aborting_loop _parent_task_parent_cancel_requestedset_tasks_errors _base_error_on_completed_futselfs +/usr/lib64/python3.12/asyncio/taskgroups.py__init__zTaskGroup.__init__ sN
(-%e !% c x dg}| j r'|j dt | j | j r'|j dt | j | j r|j d n | j
r|j d dj
| }d| dS ) N ztasks=zerrors=
cancellingentered z
)r appendlenr r r join)r infoinfo_strs r __repr__zTaskGroup.__repr__( s t ;; KK&T[[!1 23 4 << KK'#dll"3!45 6 >> KK %
]] KK "88D>H:Q''r c K | j rt d| d | j t j | _ t j | j | _ | j t d| d d| _ | S w)N
TaskGroup z has already been enteredz! cannot determine the parent taskT)r RuntimeErrorr r get_running_loopr current_taskr
r s r
__aenter__zTaskGroup.__aenter__6 s == TH$=>@
@ :: 002DJ ! . .tzz : $ TH$EFH
H
s B B c K d } | j || d { d | _ d | _ d | _ d }S 7 # d | _ d | _ d | _ d }w xY wwN)_aexitr
r r )r etexctbs r __aexit__zTaskGroup.__aexit__D sc
R-- !%D DL #D C . !%D DL #D Cs% A9 79 A9 AAc K d| _ |$| j | r| j || _ |t j u r|nd }| j
r | j j dk( rd }| | j s| j | j rT| j | j j | _ | j d { d | _ | j rT| j
| j |r| j s |d }|-|t j ur| j j | | j r t! d| j d y 7 # t j $ r(}| j s|}| j Y d }~d }~ww xY w# d }w xY w# d }w xY w# d }w xY w# d }w xY ww)NT z unhandled errors in a TaskGroup)r
_is_base_errorr r CancelledErrorr r
uncancelr _abortr r r
create_futurer r BaseExceptionGroup)r r. r/ propagate_cancellation_errorexs r r- zTaskGroup._aexitR s
O##C( ( "D 222C % ( ( ))+q0 04,
>>>
kk%%-)-)A)A)C&
",,,, &*D "' kk. '
&&& 0+DLL 66 ,0 (
>b
(A(A A LL $ <<
(5LL M - ,,
"~~ 460KKM
"* C+/ ( s CG E2 E0E2 G / G < F0 F> F7 =G G /G 0E2 2F- F(#G (F--G 0F44G 7F;;F> >GG G G N)namecontextc | j st d| d | j r| j st d| d | j rt d| d | | j
j
| }n | j
j
|| }t j || | j j | |j | j |~S # ~w xY w)Nr& z has not been enteredz is finishedz is shutting down)r= ) r r' r
r r r create_taskr _set_task_nameaddadd_done_callback
_on_task_done)r coror< r= tasks r r? zTaskGroup.create_task s }} D83H IJ J == D8< @A A >> D83D EF F ?::))$/D::))$)@D
T4(
t 1 12 s 'C* *C-r/ returnc . t |t t f S r, )
isinstance
SystemExitKeyboardInterrupt)r r/ s r r4 zTaskGroup._is_base_error s #
,= >??r c v d| _ | j D ]# }|j r|j % y )NT)r r donecancel)r ts r r7 zTaskGroup._abort s) A668
r c | j j | | j A| j s5| j j s| j j d |j ry |j
}|y | j j | | j | r| j || _
| j j r1| j j d|d| j d||d y | j s?| j s2| j! d| _ | j j# y y y )NTzTask z% has errored out but its parent task z is already completed)message exceptionrE )r discardr rL
set_result cancelledrQ r r r4 r r
r call_exception_handlerr r r7 rM )r rE r/ s r rC zTaskGroup._on_task_done s3 D! ! ! -dkk))..0&&11$7 >> nn ; C s #(8(8(@ "D ! ! #
JJ - - "4( +##'#4#4"55J L /
~~d&C&C&
KKM,0D ) $ $ &+ 'D~r )__name__
__module__ __qualname__r r$ r* r1 r- r?
BaseExceptionboolr4 r7 rC r r r r sO
& ( Wt )-d F@- @D @2'r r N)__all__r r r r r r[ r r r] s!
@' @'r