�
<��g^ � �b � d dl mZ G d� d� � Z G d� d� � Z G d� de� � ZdS ) � )�dequec �2 � e Zd ZdZd� Zd� Zd� Zd� Zd d�ZdS )
� Transactiona Filesystem transaction write context
Gathers files for deferred commit or discard, so that several write
operations can be finalized semi-atomically. This works by having this
instance as the ``.transaction`` attribute of the given filesystem
c �: � || _ t � � | _ dS )�O
Parameters
----------
fs: FileSystem instance
N)�fsr �files)�selfr �kwargss �b/home/asafur/pinokio/api/open-webui.git/app/env/lib/python3.11/site-packages/fsspec/transaction.py�__init__zTransaction.__init__ s � � ����W�W��
�
�
� c �. � | � � � | S �N)�start�r
s r � __enter__zTransaction.__enter__ s � � �
�
� � � �� r c � � | � |du �� � | j r!d| j _ d| j _ d| _ dS dS )z;End transaction and commit, if exit is not due to exceptionN)�commitF)�completer �_intrans� _transaction)r
�exc_type�exc_val�exc_tbs r �__exit__zTransaction.__exit__ sP � �
�
�
�X�� -�
�.�.�.� �7� � $�D�G� �#'�D�G� ��D�G�G�G� � r c �D � t � � | _ d| j _ dS )z&Start a transaction on this FileSystemTN)r r r r r s r r zTransaction.start" s � ��W�W��
� �����r Tc �� � | j rK| j � � � }|r|� � � n|� � � | j �Kd| j _ d| j _ d| _ dS �z8Finish transaction: commit or discard all deferred filesFN)r �popleftr �discardr r r )r
r �fs r r zTransaction.complete' sp � ��j� ��
�"�"�$�$�A��
����
�
�
�
�� � � � � � �j� � !���� #��� �����r N�T) �__name__�
__module__� __qualname__�__doc__r
r r r r � r r r r sn � � � � � �� � � � �� � �� � � � � �
�
�
�
�
�
r r c �& � e Zd Zd� Zd� Zd� Zd� ZdS )� FileActorc � � g | _ d S r )r r s r r
zFileActor.__init__5 s
� ���
�
�
r c �t � | j D ]}|� � � �| j � � � d S r )r r �clear�r
r" s r r zFileActor.commit8 s< � ��� � �A�
�H�H�J�J�J�J� �
�������r c �t � | j D ]}|� � � �| j � � � d S r )r r! r- r. s r r! zFileActor.discard= s< � ��� � �A�
�I�I�K�K�K�K� �
�������r c �: � | j � |� � d S r )r �appendr. s r r1 zFileActor.appendB s � � �
���!� � � � � r N)r$ r% r& r
r r! r1 r( r r r* r* 4 sP � � � � � �� � �� � �
� � �
� � � � r r* c �& � � e Zd Z� fd�Zdd�Z� xZS )�DaskTransactionc �� �� ddl }t � � � |� � |� � � }|� t
d�� � � � � | _ dS )r r NT)�actor)� distributed�superr
�default_client�submitr* �resultr )r
r r6 �client� __class__s �r r
zDaskTransaction.__init__G sa �� � ����
������ � � � �+�+�-�-���]�]�9�D�]�9�9�@�@�B�B��
�
�
r Tc �� � |r,| j � � � � � � n+| j � � � � � � d| j _ d| _ dS r )r r r: r! r r )r
r s r r zDaskTransaction.completeS sb � � � *� �J� � � � � &� &� (� (� (� (� �J� � � � � '� '� )� )� )� ��������r r# )r$ r% r& r
r �
__classcell__)r< s @r r3 r3 F sQ �� � � � � �
C�
C�
C�
C�
C�� � � � � � � r r3 N)� collectionsr r r* r3 r( r r �<module>r@ s� �� � � � � � �-� -� -� -� -� -� -� -�` � � � � � � � �$� � � � �k� � � � � r