/snap/core24/1643/usr/lib/python3.12/asyncio/__pycache__
Edit: /snap/core24/1643/usr/lib/python3.12/asyncio/__pycache__/taskgroups.cpython-312.pyc (7927B)
Цi+" @ d Z ddlmZ ddlmZ ddlmZ G d d Zy)) TaskGroup )events)
exceptions)tasksc R e Zd ZdZd Zd Zd Zd ZddddZd e d
e
fd Z d Z d
Z
y)r a9 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 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/lib/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 | 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 rJ | j | j |r| j s||-|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 ww)NT z unhandled errors in a TaskGroup)r
_is_base_errorr r CancelledErrorr r
uncancelr _abortr r r
create_futurer r BaseExceptionGroup)r etexctb propagate_cancellation_errorexmes r __aexit__zTaskGroup.__aexit__D s
O##C( ( "D 222C % ( ( ))+q0 04,
>>>
kk%%-)-)A)A)C&
",,,, &*D "' kk* ;; '"" " ( . .
>b
(A(A A LL $ <<
$'(I4<<Xd"
; - ,,
"~~ 460KKM
"H $ sa CGE= E;E= G/A1G!F; :G;E= =F8 F3.G3F88G; GGN)namecontextc | j st d| d | j r| j st d| d | j rt d| d | | j
j
| }n | j
j
|| }t j || |j r| j | |S | j j | |j | j |S )zbCreate a new task in this group and return it.
Similar to `asyncio.create_task`.
r& z has not been enteredz is finishedz is shutting down)r; )
r r' r
r r r create_taskr _set_task_namedone
_on_task_doneaddadd_done_callback)r coror: r; tasks r r= zTaskGroup.create_task s
}} D83H IJ J == D8< @A A >> D83D EF F ?::))$/D::))$)@D
T4( 99; t $
KKOOD ! " "4#5#5 6 r r4 returnc R t |t sJ t |t t f S )N)
isinstance
BaseException
SystemExitKeyboardInterrupt)r r4 s r r- zTaskGroup._is_base_error s% #}---#
,= >??r c v d| _ | j D ]# }|j r|j % y )NT)r r r? cancel)r ts r r0 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 exceptionrD )r discardr r?
set_result cancelledrP r r r- r r
r call_exception_handlerr r r0 rL )r rD r4 s r r@ 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____doc__r r$ r* r9 r= rH boolr- r0 r@ r r r r sI
& ( O$b )-d <@- @D @2'r r N)__all__r r r r r rZ r r r\ s!
d' d'r