← Back
Editing: runners.cpython-313.opt-2.pyc
� M��i> � � � S r SSKrSSKrSSKrSSKrSSKrSSKJr SSKJr SSKJ r SSKJ r SSKJ r " S S \R 5 r " S S 5 rSSS .S jrS rg))�Runner�run� N� )� coroutines)�events)� exceptions)�tasks)� constantsc � � \ rS rSrSrSrSrSrg)�_State� �created� initialized�closed� N)�__name__� __module__� __qualname__�__firstlineno__�CREATED� INITIALIZED�CLOSED�__static_attributes__r � �6/opt/alt/python313/lib64/python3.13/asyncio/runners.pyr r s � ��G� �K� �Fr r c �V � \ rS rSrSSS.S jrS rS rS rS rSS .S jr S r S r S r g)r � N��debug� loop_factoryc �~ � [ R U l Xl X l S U l S U l SU l SU l g )Nr F) r r �_state�_debug� _loop_factory�_loop�_context�_interrupt_count�_set_event_loop)�selfr r s r �__init__�Runner.__init__0 s6 � � �n�n�� �� � )���� � �� � !�� � $�� r c �& � U R 5 U $ �N)� _lazy_init�r) s r � __enter__�Runner.__enter__9 s � � ����� r c �$ � U R 5 g r- )�close)r) �exc_type�exc_val�exc_tbs r �__exit__�Runner.__exit__= s � � � � � r c �` � U R [ R La g U R n[ U5 UR UR 5 5 UR UR [ R 5 5 U R ( a [ R " S 5 UR 5 S U l [ R U l g ! U R ( a [ R " S 5 WR 5 S U l [ R U l f = fr- )r" r r r% �_cancel_all_tasks�run_until_complete�shutdown_asyncgens�shutdown_default_executorr �THREAD_JOIN_TIMEOUTr( r �set_event_loopr3 r )r) �loops r r3 � Runner.close@ s� � � �;�;�f� 0� 0� 0� � (��:�:�D� �d� #� � #� #�D�$;�$;�$=� >� � #� #��.�.�y�/L�/L�M� O� �#�#��%�%�d�+� �J�J�L� �D�J� �-�-�D�K�� �#�#��%�%�d�+� �J�J�L� �D�J� �-�-�D�K�s �A$C �AD-c �: � U R 5 U R $ r- )r. r% r/ s r �get_loop�Runner.get_loopQ s � � �����z�z�r ��contextc � � [ R " U5 ( d [ SR U5 5 e[ R " 5 b [ S5 eU R 5 Uc U R nU R R XS9n[ R " 5 [ R " 5 L a{ [ R " [ R 5 [ R" L aF [$ R& " U R( US9n [ R " [ R U5 OS nSU l U R R- U5 Ub\ [ R " [ R 5 UL a4 [ R " [ R [ R" 5 $ $ $ ! [ a S n N�f = f! [. R0 a7 U R* S:� a% [3 USS 5 nUb U" 5 S:X a [5 5 ee f = f! Ub\ [ R " [ R 5 UL a4 [ R " [ R [ R" 5 f f f = f)Nz"a coroutine was expected, got {!r}z7Runner.run() cannot be called from a running event looprE )� main_taskr �uncancel)r � iscoroutine� ValueError�formatr �_get_running_loop� RuntimeErrorr. r& r% � create_task� threading�current_thread� main_thread�signal� getsignal�SIGINT�default_int_handler� functools�partial� _on_sigintr' r; r �CancelledError�getattr�KeyboardInterrupt)r) �cororF �task�sigint_handlerrI s r r � Runner.runV s� � ��%�%�d�+�+� � A� H� H�� N�O� O� � #� #� %� 1� �I�K� K� ���� �?��m�m�G��z�z�%�%�d�%�<�� � $� $� &�)�*?�*?�*A� A�� � �� � �/�6�3M�3M�M� &� .� .�t���$� O�N� &�� � �f�m�m�^�<� "�N� !�� � I��:�:�0�0��6� �*��$�$�V�]�]�3�~�E�� � �f�m�m�V�-G�-G�H� F� +��% � &� "&�� &�� �(�(� ��$�$�q�(�"�4��T�:���'�H�J�!�O�+�-�-� � �� �*��$�$�V�]�]�3�~�E�� � �f�m�m�V�-G�-G�H� F� +�s, �%F9 �?G �9 G�G� A H�H �A!I:c �< � U R [ R L a [ S5 eU R [ R L a g U R cS [ R " 5 U l U R ( d' [ R " U R 5 SU l OU R 5 U l U R b% U R R U R 5 [ R " 5 U l [ R U l g )NzRunner is closedT)r" r r rN r r$ r �new_event_loopr% r( r? r# � set_debug� contextvars� copy_contextr& r/ s r r. �Runner._lazy_init� s� � � �;�;�&�-�-� '� � 1�2� 2� �;�;�&�,�,� ,� � � � � %� �.�.�0�D�J��'�'� �%�%�d�j�j�1�'+��$�� �+�+�-�D�J� �;�;� "� �J�J� � ���� -�#�0�0�2�� � �(�(�� r c �� � U =R S- sl U R S:X aB UR 5 ( d- UR 5 U R R S 5 g [ 5 e)Nr c � � g r- r r r r �<lambda>�#Runner._on_sigint.<locals>.<lambda>� s � �Dr )r' �done�cancelr% �call_soon_threadsafer\ )r) �signum�framerH s r rY �Runner._on_sigint� sW � � � � ��"� � � � �A� %�i�n�n�.>�.>� � � � � �J�J� +� +�L� 9� � �!�!r )r& r# r' r% r$ r( r" ) r r r r r* r0 r7 r3 rC r r. rY r r r r r r s8 � �8 !%�4� %���(�"� $(� +I�Z)�&"r r r c � � [ R " 5 b [ S5 e[ XS9 nUR U 5 sS S S 5 $ ! , ( d f g = f)Nz8asyncio.run() cannot be called from a running event loopr )r rM rN r r )�mainr r �runners r r r � sI � �: � � �!�-�� F�H� H� �e� 7�6��z�z�$� � 8� 7� 7�s �A� Ac �h � [ R " U 5 nU( d g U H nUR 5 M U R [ R " USS065 U HP nUR 5 ( a M UR 5 c M- U R SUR 5 US.5 MR g )N�return_exceptionsTz1unhandled exception during asyncio.run() shutdown)�message� exceptionr^ )r � all_tasksrl r; �gather� cancelledrw �call_exception_handler)r@ � to_cancelr^ s r r: r: � s� � �����%�I� ���� � � � � � ���E�L�L�)� L�t� L�M��� �>�>� � � � �>�>� � '� � '� '�N� !�^�^� -� �)� � r )�__all__rd �enumrW rP rS � r r r r r �Enumr r r r: r r r �<module>r� sW �� �� � � � � � � � � � ��T�Y�Y� � I"� I"�X �$� # �Lr
Save File
Cancel