OwlCyberSecurity - MANAGER
Edit File: concurrency.cpython-312.pyc
� ̓�g� � �h � d dl mZ d dlZd dlZd dlmZ d dlmZ d dlmZ d dlmZ dZdZ d dl Z dZd d l m Z d d l m Z d d l mZ d d l mZ d dl mZ d dl mZ d dl mZ ed� Z G d� d� Zej0 s es d� Zd� Zd� Z d� Z d� Zd� Zd� Zd� Zd � Zyyy# e$ rZ ee� Z Y dZ[�PdZ[ww xY w) � )� annotationsN)�Any)�Callable)� Coroutine)�TypeVarFT� )� await_only)�await_fallback)� in_greenlet)�greenlet_spawn)�is_exit_exception)�AsyncAdaptedLock)�_Runner�_Tc �P � e Zd ZdZdd�Z dd�Z d d�Zdd�Zy) � _AsyncUtilz&Asyncio util for test suite/ util onlyc �0 � t rt � | _ y y �N)� have_greenletr �runner��selfs �L/opt/hc_python/lib64/python3.12/site-packages/sqlalchemy/util/concurrency.py�__init__z_AsyncUtil.__init__) s � � �!�)�D�K� � c �D � | j j ||i |��� S )zRun coroutine on the loop)r �run�r �fn�args�kwargss r r z_AsyncUtil.run- s! � � �{�{���r�4� 2�6� 2�3�3r c �� � t rX| j j � j � r ||i |��S | j j t |g|��i |��� S ||i |��S )z3Run sync function in greenlet. Support nested calls)r r �get_loop� is_runningr r r s r �run_in_greenletz_AsyncUtil.run_in_greenlet6 sb � � ��{�{�#�#�%�0�0�2��4�*�6�*�*��{�{���~�b�'J�4�'J�6�'J�K�K��t�&�v�&� &r c �F � t r| j j � y y r )r r �closer s r r' z_AsyncUtil.closeB s � � � �K�K� � � � r N)�return�None)r z&Callable[..., Coroutine[Any, Any, _T]]r r r! r r( r )r zCallable[..., _T]r r r! r r( r )�__name__� __module__� __qualname__�__doc__r r r% r' � r r r r & s_ � �0�$�4� 2�4� �4� � 4� � 4� '�#� '�,/� '�;>� '� � '� r r c �L � t ry t t r dt z � �d� �)Nz9the greenlet library is required to use this function. %s� )r � ValueError�greenlet_errorr. r r �_not_implementedr3 I s8 � � ��� � �"� #� � � � � r c �$ � t | t � S r )� isinstance� Exception)�es r r r V s � � �a��+�+�+r c � � t � y r �r3 ��things r r r Y � � ��r c � � | S r r. r: s r r r \ s � �� r c � � t � y r r9 r. r r r r _ r< r c � � t � y r r9 )r r �kws r r r b r< r c � � t � y r r9 )r r@ s r r r e r< r c � � | |i |��S r r. �r �argr@ s r �_util_async_runrE h s � ��3�~�"�~� r c � � t � y r r9 rC s r �"_util_async_run_coroutine_functionrG k r< r ) � __future__r �asyncio�typingr r r r r r2 �greenlet�_concurrency_py3kr r r r r r r � ImportErrorr7 �strr r � TYPE_CHECKINGr3 rE rG r. r r �<module>rP s� �� #� � � � � � �� ��� +�� �M�;�C�=�C�I�G�*� �T�]�� � �B ���M� �,������ ��I %2���c � ���V�N��� �s �B �B1� B,�,B1