*jA' @ S r SSKJr SSKJr SSKJr " S S5 rg)) TaskGroup )events)
exceptions)tasksc d \ rS rSrSrS rS rS rS rS r SSS .S
jr
S \ S \ 4S
jr
S rS rSrg)r a Asynchronous context manager for managing groups of tasks.
Example use:
async with asyncio.TaskGroup() as group:
task1 = group.create_task(some_coroutine(...))
task2 = group.create_task(other_coroutine(...))
print("Both tasks have completed now.")
All tasks are awaited when the context manager exits.
Any exceptions other than `asyncio.CancelledError` raised within
a task will cancel all remaining tasks and wait for them to exit.
The exceptions are then combined and raised as an `ExceptionGroup`.
c SU l SU l SU l S U l S U l SU l [
5 U l / U l S U l S U l
g )NF) _entered_exiting _aborting_loop _parent_task_parent_cancel_requestedset_tasks_errors _base_error_on_completed_futselfs 9/opt/alt/python313/lib64/python3.13/asyncio/taskgroups.py__init__TaskGroup.__init__ sN
(-%e !% c S/nU R ( a' UR S[ U R 5 35 U R ( a' UR S[ U R 5 35 U R ( a UR S5 O"U R
( a UR S5 SR
U5 nSU S3$ ) N ztasks=zerrors=
cancellingentered z
)r appendlenr r r
join)r infoinfo_strs r __repr__TaskGroup.__repr__( s t ;; KK&T[[!1 23 4 << KK'#dll"3!45 6 >> KK %
]] KK "88D>H:Q''r c 0 # U R ( a [ SU < S35 eU R c [ R " 5 U l [
R " U R 5 U l U R c [ SU < S35 eSU l U $ 7f)N
TaskGroup z has already been enteredz! cannot determine the parent taskT)r
RuntimeErrorr
r get_running_loopr current_taskr r s r
__aenter__TaskGroup.__aenter__6 s == TH$=>@
@ :: 002DJ ! . .tzz : $ TH$EFH
H
s BBc # S n U R X5 I S h vN S U l S U l S U l S n$ N! S U l S U l S U l S nf = f7fN)_aexitr r r )r etexctbs r __aexit__TaskGroup.__aexit__D s`
R-- !%D DL #D C . !%D DL #D Cs% A8 68 A8 AAc # SU l Ub) U R U5 ( a U R c X l Ub" [ U[ R
5 ( a UnOS nUb! U R ( d U R 5 U R ( a[ U R c U R R 5 U l U R I S h vN S U l U R ( a M[ U R b
U R eU R ( a U R R 5 S:X a S n Ub U R ( d UeS nUb: [ U[ R
5 ( d U R R! U5 U R ( ak U R R# 5 ( a4 U R R 5 U R R% 5 [' SU R 5 S eg GN>! [ R
a. nU R ( d UnU R 5 S nAGNyS nAff = f! S nf = f! S nf = f! S nf = f! S nf = f7f)NT z unhandled errors in a TaskGroup)r _is_base_errorr
issubclassr CancelledErrorr _abortr r r
create_futurer r uncancelr r! r cancelBaseExceptionGroup)r r2 r3 propagate_cancellation_errorexs r r1 TaskGroup._aexitR s
O##C(( ( "
>jZ-F-F G G+. (+/ (
>>>
kk%%-)-)A)A)C&
",,,, &*D "' kkk. '
&&& ( ( ))+q0 04, 0+7 66 ,0 (
>*R1J1J"K"K LL $ << ++--!!**,!!((*
(5LL [ - ,,
"~~ 460KKM
"* C+/ ($ s B> JJL D83D EF F ?::))$):D::))$7)KD
t 1 12 s D Dr3 returnc . [ U[ [ 45 $ r0 )
isinstance
SystemExitKeyboardInterrupt)r r3 s r r9 TaskGroup._is_base_error s #
,= >??r c SU l U R H* nUR 5 ( a M UR 5 M, g )NT)r r doner? )r ts r r< TaskGroup._abort s+ A6688
r c U R R U5 U R bK U R ( d: U R R 5 ( d U R R S5 UR 5 ( a g UR
5 nUc g U R R U5 U R U5 ( a U R c X l
U R R 5 ( a2 U R R SU< SU R S3UUS.5 g U R ( dD U R ( d2 U R! 5 SU l U R R# 5 g g g )NTzTask z% has errored out but its parent task z is already completed)message exceptionrN )r discardr rW
set_result cancelledr\ r r! r9 r r r
call_exception_handlerr r r< r? )r rN r3 s r rL TaskGroup._on_task_done s= D! ! ! -dkk))..00&&11$7 >> nn ; C s # #(8(8(@ " ! ! # #
JJ - - "4( +##'#4#4"55J L /
~~d&C&C&
KKM,0D ) $ $ &+ 'D~r )
r r r
r r r
r r r r )__name__
__module__ __qualname____firstlineno____doc__r r& r- r5 r1 rI
BaseExceptionboolr9 r< rL __static_attributes__ r r r r sO
& ( `F )-d H@- @D @2'r r N)__all__r r r r r rj r r rl s!
J' J'r