+
    iV'  c                   sN    Rt ^RIHt ^RIHt ^RIHt ^RIHt  ! R R 4      tR# )	TaskGroup)events)
exceptions)futures)tasksc                   sb   a  ] tR t^t o R tR tR tR tR tR t	V 3R lR lt
R	 tR
 tRtV tR# )r    c                s    R V n         R V n        R V n        RV n        RV n        R V n        \        4       V n        . V n        RV n	        RV n
        R# )FN)_entered_exiting	_aborting_loop_parent_task_parent_cancel_requestedZset_tasks_errors_base_error_on_completed_futself   &+/usr/lib64/python3.14/asyncio/taskgroups.py__init__ZTaskGroup.__init__   sN    
 (-%e!%    c                s   R .pV P                   '       d(   VP                  R\        V P                   4       24       V P                  '       d(   VP                  R\        V P                  4       24       V P                  '       d   VP                  R4       M#V P
                  '       d   VP                  R4       RP                  V4      pRV R2# ) ztasks=zerrors=
cancellingZenteredZ z
<TaskGroupZ>)r   appendZlenr   r   r   Zjoin)r   ZinfoZinfo_strs   &  r   __repr__ZTaskGroup.__repr__)   s    t;;;KK&T[[!1 234<<<KK'#dll"3!456>>>KK%]]]KK	"88D>H:Q''r   c                s6  "   V P                   '       d   \        R V : R24      hV P                  f   \        P                  ! 4       V n        \
        P                  ! V P                  4      V n        V P                  f   \        R V : R24      hRV n         V # 5i)
TaskGroup z has already been enteredz! cannot determine the parent taskT)r   RuntimeErrorr   r   Zget_running_loopr   Zcurrent_taskr	   r   r   r   
__aenter__ZTaskGroup.__aenter__7   s     ===TH$=>@ @::002DJ!..tzz:$TH$EFH Hs   BBc                s   "   R p V P                  W4      G R j  xL
 R V n        R V n        R V n        R p#  L  R T n        R T n        R T n        R pi ; i5iN)_aexitr	   r   r   )r   etexcZtbs   &&&&r   	__aexit__ZTaskGroup.__aexit__E   s`     
	R-- !%DDL#DC . !%DDL#DCs%   A8 68 A8 AAc                s  "   R V n         Ve,   V P                  V4      '       d   V P                  f   W n        Ve$   \        V\        P
                  4      '       d   TpMRpVe#   V P                  '       g   V P                  4        V P                  '       dL   V P                  f    V P                  P                  4       V n	         V P                  G Rj  xL
  RV n	        K]  V P                  e    V P                  hV P                  '       d"   V P                  P                  4       ^ 8X  d   Rp Ve   V P                  '       g    VhRpVe<   \        V\        P
                  4      '       g   V P                  P!                  V4       V P                  '       dm   V P                  P#                  4       '       d5   V P                  P                  4        V P                  P%                  4         \'        RV P                  4      RhR#  EL7  \        P
                   d0   pT P                  '       g   TpT P                  4         Rp?ELtRp?ii ; i  Rpi ; i  Rpi ; i  Rpi ; i  Rpi ; i5i)TNzunhandled errors in a TaskGroup)r   _is_base_errorr   Z
issubclassr   ZCancelledErrorr   _abortr   r   r   Zcreate_futurer
   r	   Zuncancelr   r   r   cancelZBaseExceptionGroup)r   r   r   Zpropagate_cancellation_errorZexs   &&&  r   r   ZTaskGroup._aexitS   s    O##C((  (">jZ-F-FGG+.(+/(>>>>  kkk%%-)-)A)A)C&",,,, &*D" '&&& (((  ))+q0 04,	0+766 ,0(>*R1J1J"K"KLL$<<<   ++--!!**,!!((*(5LL  [ -,, "~~~ 460KKM"*   C+/($ s   "I4AI48!I4-I4H HH I44I  I4!I44I& I AI4 I4 4I45I- I4H I&$I
I4II4II4I##I& &I**I4-I11I4c                sL   V P                   '       g!   VP                  4        \        R V : R24      hV P                  '       d3   V P                  '       g!   VP                  4        \        R V : R24      hV P
                  '       d!   VP                  4        \        R V : R24      hV P                  P                  ! V3/ VB p\        P                  ! W0P                  4       V P                  P                  V4       VP                  V P                  4        T?#   ?i ; i)r   z has not been enteredz is finishedz is shutting down)r   Zcloser   r   r   r   r   create_taskr   Zfuture_add_to_awaited_byr	   ZaddZadd_done_callback_on_task_done)r   ZcoroZkwargstasks   &&, r   r$   ZTaskGroup.create_task   s    
 }}}JJLD83HIJJ===JJLD8<@AA>>>JJLD83DEFFzz%%d5f5((/@/@A 	t112	 s   D   D#c                s&   < V ^8  d   QhRS[ RS[/# )i   r   Zreturn)ZBaseExceptionZbool)Zformat__classdict__s   "r   Z__annotate__ZTaskGroup.__annotate__   s     @ @- @D @r   c                s.    \        V\        \        34      # r   )Z
isinstanceZ
SystemExitZKeyboardInterrupt)r   r   s   &&r   r!   ZTaskGroup._is_base_error   s    #
,=>??r   c                s    R V n         V P                   F+  pVP                  4       '       d   K  VP                  4        K-  	  R# )TN)r   r   doner#   )r   Zts   & r   r"   ZTaskGroup._abort   s+    A6688
 r   c                sv   V P                   P                  V4       \        P                  ! WP                  4       V P
                  eN   V P                   '       g<   V P
                  P                  4       '       g   V P
                  P                  R4       VP                  4       '       d   R # VP                  4       pVf   R # V P                  P                  V4       V P                  V4      '       d   V P                  f   W n        V P                  P                  4       '       d6   V P                  P                  RRV: RV P                   R2RVRV/4       R # V P                   '       gH   V P"                  '       g4   V P%                  4        RV n        V P                  P'                  4        R # R # R # )NTZmessagezTask z% has errored out but its parent task z is already completed	exceptionr&   )r   Zdiscardr   Zfuture_discard_from_awaited_byr	   r   r(   Z
set_resultZ	cancelledr)   r   r   r!   r   r   Zcall_exception_handlerr   r
   r"   r#   )r   r&   r   s   && r   r%   ZTaskGroup._on_task_done   s^   D!..t5F5FG!!-dkkk))..00&&11$7>>nn;C s##(8(8(@"!!## JJ--U4( +##'#4#4"55JLS	/  ~~~d&C&C&C& KKM,0D)$$&+ 'D~r   )
r   r   r   r   r   r   r   r
   r	   r   N)Z__name__Z
__module__Z__qualname__Z__firstlineno__r   r   r   r    r   r$   r!   r"   r%   Z__static_attributes__Z__classdictcell__)r'   s   @r   r    r       sA      
&(`FF@ @4' 4'r   N)r    )Z__all__r   r   r   r   r   r    ) r   r   <module>r*      s$   
     K' K'r   