← Back
Editing: taskgroups.cpython-313.pyc
� M��iA' � �@ � 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_requested�set�_tasks�_errors� _base_error�_on_completed_fut��selfs �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=� cancelling�entered� z <TaskGroup�>)r �append�lenr r r �join)r �info�info_strs r �__repr__�TaskGroup.__repr__( s� � ��t�� �;�;� �K�K�&��T�[�[�!1� 2�3� 4� �<�<� �K�K�'�#�d�l�l�"3�!4�5� 6� �>�>� �K�K� � %� �]�]� �K�K� � "��8�8�D�>���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� � � � �=�=� � �T�H�$=�>�@� @� �:�:� � �0�0�2�D�J� !� .� .�t�z�z� :��� � � � $� � �T�H�$E�F�H� H� �� �� �s �BBc � � # � S n U R X5 I S h v�N S U l S U l S U l S n$ N! S U l S U l S U l S nf = f7f�N)�_aexitr r r )r �et�exc�tbs r � __aexit__�TaskGroup.__aexit__D s` � � � �� � ���R�-�-� !%�D� � �D�L� #�D� ��C� .�� !%�D� � �D�L� #�D� ��C�s% �A�8 �6�8 �A�8 �A�Ac � � # � 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 v�N S U l U R ( a M[ U R ( a eU 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 GNQ! [ R a. nU R ( d UnU R 5 S nAGN�S 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 �cancel�BaseExceptionGroup)r r2 r3 � propagate_cancellation_error�exs r r1 �TaskGroup._aexitR s � � � �� � �O��#�#�C�(�(�� � �(� "� � �>�j��Z�-F�-F� G� G�+.� (�+/� (� �>��>�>� � � � � �k�k��%�%�-�)-���)A�)A�)C��&� "��,�,�,�,� &*�D� "�' �k�k�k�* �;�;� �� � � � '� ��&�&�&� � (� (�� � �)�)�+�q�0� 04�,� 0�+�7�� � � �6�6� ,0� (� �>�*�R��1J�1J�"K�"K� �L�L� � �� $� �<�<� � � �+�+�-�-��!�!�*�*�,��!�!�(�(�*� �(�5��L�L�� � � �[ -�� �,�,� "��~�~� 46�0��K�K�M��� "��* ��� �C��+/� (��$ ��s� �B<J�?H" �H �H" �J�- J� I' �1J� I5 �!I. �#B#J�I< � J� H" �"I$�6#I �J� I$�$J�'I+�+J�.I2�2I5 �5I9�9J�<J � JN��name�contextc �8 � U R ( d UR 5 [ SU < S35 eU R ( a1 U R ( d UR 5 [ SU < S35 eU R ( a UR 5 [ SU < S35 eUc U R R XS9nOU R R XUS9nU R R U5 UR U R 5 UA$ ! Af = f)zRCreate 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)rE rD ) r �closer* r r r r � create_task�add�add_done_callback� _on_task_done)r �cororE rF �tasks r rI �TaskGroup.create_task� s� � � �}�}� �J�J�L� ��D�8�3H� I�J� J� �=�=���� �J�J�L� ��D�8�<� @�A� A� �>�>� �J�J�L� ��D�8�3D� E�F� F� �?��:�:�)�)�$�)�:�D��:�:�)�)�$�7�)�K�D� � � ���� � � � �t� 1� 1�2� �� ���s �D �Dr3 �returnc �\ � [ U[ 5 ( d e[ U[ [ 45 $ r0 )� isinstance� BaseException� SystemExit�KeyboardInterrupt)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+ � � ������A��6�6�8�8���� � 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 rX � 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�!� � !� !� -�d�k�k��)�)�.�.�0�0��&�&�1�1�$�7� �>�>� � � ��n�n� �� �;� � � � ���C� � � � �s� #� #��(8�(8�(@� "� � � � � !� !� #� #� �J�J� -� -� "�4�(� +#�#'�#4�#4�"5�5J� L� � � /� � ��~�~�d�&C�&C�& �K�K�M�,0�D� )� � � � $� $� &�+ 'D�~r ) r r r r r r r r r r )�__name__� __module__� __qualname__�__firstlineno__�__doc__r r& r- r5 r1 rI rS �boolr9 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 �<module>rl s! �� �� � � �J'� J'r
Save File
Cancel