← Back
Editing: async_helpers.cpython-311.pyc
� �@�c� � � � d Z ddlZddlZddlZddlmZ dad� Z G d� d� � Z e� � Z G d� d� � Z d � Z d � Z d � Z d ed efd�ZdS )a� Async helper function that are invalid syntax on Python 3.5 and below. This code is best effort, and may have edge cases not behaving as expected. In particular it contain a number of heuristics to detect whether code is effectively async and need to run in an event loop or not. Some constructs (like top-level `return`, or `yield`) are taken care of explicitly to actually raise a SyntaxError and stay as close as possible to Python semantics. � N)�wrapsc � � t j � � S # t $ r Y nw xY wt �t � � � rt j � � at S )aZ asyncio has deprecated get_event_loop Replicate it here, with our desired semantics: - always returns a valid, not-closed loop - not thread-local like asyncio's, because we only want one loop for IPython - if called from inside a coroutine (e.g. in ipykernel), return the running loop .. versionadded:: 8.0 )�asyncio�get_running_loop� RuntimeError�_asyncio_event_loop� is_closed�new_event_loop� � �</usr/lib/python3/dist-packages/IPython/core/async_helpers.py�get_asyncio_loopr sg � � ��'�)�)�)�� � � � � �� ���� �"�&9�&C�&C�&E�&E�"� %� 4� 6� 6�� � s � � "�"c � � e Zd Zd� Zd� ZdS )�_AsyncIORunnerc �D � t � � � |� � S )z/ Handler for asyncio autoawait )r �run_until_complete)�self�coros r �__call__z_AsyncIORunner.__call__4 s � � �!�!�4�4�T�:�:�:r c � � dS )Nr r �r s r �__str__z_AsyncIORunner.__str__: s � ��yr N)�__name__� __module__� __qualname__r r r r r r r 3 s2 � � � � � �;� ;� ;� � � � � r r c �* � e Zd ZdZd� Zd� Zd� Zd� ZdS )� _AsyncIOProxyz^Proxy-object for an asyncio Any coroutine methods will be wrapped in event_loop.run_ c �" � || _ || _ d S �N)�_obj� _event_loop)r �obj� event_loops r �__init__z_AsyncIOProxy.__init__G s � ��� �%����r c � � d| j �d�S )Nz<_AsyncIOProxy(z)>)r r s r �__repr__z_AsyncIOProxy.__repr__K s � �0���0�0�0�0r c � � �� t � j |� � �t j �� � r t �� � �� fd�� � }|S �S )Nc �l �� t j �| i |���j � � }t j |� � S r )r �run_coroutine_threadsafer! � wrap_future)�args�kwargs�concurrent_future�attrr s ��r �_wrappedz+_AsyncIOProxy.__getattr__.<locals>._wrappedS sA �� �$+�$D��D�$�)�&�)�)�4�+;�%� %�!� �*�+<�=�=�=r )�getattrr �inspect�iscoroutinefunctionr )r �keyr/ r. s ` @r � __getattr__z_AsyncIOProxy.__getattr__N sd ��� ��t�y�#�&�&�� � &�t� ,� ,� � �4�[�[� >� >� >� >� >� �[� >� �O��Kr c �* � t | j � � S r )�dirr r s r �__dir__z_AsyncIOProxy.__dir__^ s � ��4�9�~�~� r N)r r r �__doc__r$ r& r4 r7 r r r r r A sZ � � � � � �� � &� &� &�1� 1� 1�� � � � � � � r r c �4 � ddl }|� | � � S )z% handler for curio autoawait r N)�curio�run)� coroutiner: s r � _curio_runnerr= b s � � �L�L�L� �9�9�Y� � � r c �< � dd l }d� }|� || � � S )Nr c � � K � | � d{V ��S )z� We need the dummy no-op async def to protect from trio's internal. See https://github.com/python-trio/trio/issues/89 Nr )r s r �locz_trio_runner.<locals>.locn s � � � � �z�z�z�z�z�z�r )�trior; )�async_fnrA r@ s r � _trio_runnerrC k s0 � ��K�K�K�� � � �8�8�C�� "� "�"r c � � | � d� � t d� | j �� � � � �# t $ r}|j cY d}~S d}~ww xY w)z� A runner that does not really allow async execution, and just advance the coroutine. See discussion in https://github.com/python-trio/trio/issues/608, Credit to Nathaniel Smith Nz%{coro_name!r} needs a real async loop)� coro_name)�sendr �formatr � StopIteration�value)r �excs r �_pseudo_sync_runnerrK x sx � � � � � �$���� � 3� :� :�T�]� :� S� S� � � �� � � � ��y��������������s �? � A� A�A�A�cell�returnc �� � t | ddt t dd� � �� � }t j |j z t j k S # t t f$ r Y dS w xY w)a� Detect if a block of code need to be wrapped in an `async def` Attempt to parse the block of code, it it compile we're fine. Otherwise we wrap if and try to compile. If it works, assume it should be async. Otherwise Return False. Not handled yet: If the block of code has a return statement as the top level, it will be seen as async. This is a know limitation. z<>�exec�PyCF_ALLOW_TOP_LEVEL_AWAITr )�flagsF)�compiler0 �astr1 � CO_COROUTINE�co_flags� SyntaxError� MemoryError)rL �codes r �_should_be_asyncrY � ss � ��� �$��g�c�3O�QT�&U�&U� � � �� �#�d�m�3�w�7K�K�K�� �� %� � � ��u�u����s �AA � A � A )r8 rS r r1 � functoolsr r r r �_asyncio_runnerr r= rC rK �str�boolrY r r r �<module>r^ s �� � � � � � � ���� ���� � � � � � �� � � � �:� � � � � � � � !�.�"�"�� � � � � � � � �B � � � #� #� #� � � �&�3� �4� � � � � � r
Save File
Cancel