�
J�g� � �F � d dl mZ erd dlmZmZ d� Z G d� d� � ZdS )� )�
TYPE_CHECKING)�Pipeline�Redisc �* � ddl m} |j | fi |��S )z�
Returns an active Redis client generated from the given database URL.
Will attempt to extract the database id from the path url fragment, if
none is provided.
r )r )�redis.asyncio.clientr �from_url)�url�kwargsr s �c/home/asafur/pinokio/api/open-webui.git/app/env/lib/python3.11/site-packages/redis/asyncio/utils.pyr r s0 � � +�*�*�*�*�*� �5�>�#� (� (�� (� (�(� c �$ � e Zd Zd d�Zd
d�Zd� ZdS ) �pipeline� redis_objr c �8 � |� � � | _ d S �N)r �p)�selfr s r �__init__zpipeline.__init__ s � � &� /� /� 1� 1����r �returnr c � � K � | j S r )r )r s r �
__aenter__zpipeline.__aenter__ s
� � � ��v�
r c � �L K � | j � � � � d {V �� | ` d S r )r �execute)r �exc_type� exc_value� tracebacks r � __aexit__zpipeline.__aexit__ s3 � � � ��f�n�n� � � � � � � � � � �F�F�Fr N)r r )r r )�__name__�
__module__� __qualname__r r r � r r r r sK � � � � � �2� 2� 2� 2�� � � �� � � � r r N)�typingr r r r r r r! r r �<module>r# sx �� � � � � � �� 5�4�4�4�4�4�4�4�4� )� )� )� � � � � � � � � � r