← back to Atmos Game
assets/gen/.venv/lib/python3.12/site-packages/fsspec/__pycache__/transaction.cpython-312.pyc
39 lines
�
c�bj^ � �N � d dl mZ G d� d� Z G d� d� Z G d� de� Zy) � )�dequec �0 � e Zd ZdZd� Zd� Zd� Zd� Zdd�Zy) � 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 �0 � || _ t � | _ y)�O
Parameters
----------
fs: FileSystem instance
N)�fsr �files)�selfr �kwargss �i/Users/macstudio3/Projects/atmos-game/assets/gen/.venv/lib/python3.12/site-packages/fsspec/transaction.py�__init__zTransaction.__init__ s � � ����W��
� c �& � | j � | S �N)�start�r
s r � __enter__zTransaction.__enter__ s � � �
�
� �� r c � � | j |du �� | j r*d| j _ d| j _ d| _ yy)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__ sB � �
�
�
�X�� -�
�.� �7�7� $�D�G�G� �#'�D�G�G� ��D�G� r c �D � t � | _ d| j _ y)z&Start a transaction on this FileSystemTN)r r r r r s r r zTransaction.start" s � ��W��
� ����r c � � | j rJ| j j � }|r|j � n|j � | j r�Jd| j _ d| j _ d| _ y�z8Finish transaction: commit or discard all deferred filesFN)r �popleftr �discardr r r )r
r �fs r r zTransaction.complete' sZ � ��j�j��
�
�"�"�$�A�����
�� � � � �j�j� !����� #���� ���r N�T) �__name__�
__module__� __qualname__�__doc__r
r r r r � r r r r s � �� ��� �
r r c �$ � e Zd Zd� Zd� Zd� Zd� Zy)� FileActorc � � g | _ y r )r r s r r
zFileActor.__init__5 s � ���
r c �z � | j D ] }|j � � | j j � y r )r r �clear�r
r" s r r zFileActor.commit8 s) � ����A�
�H�H�J� � �
�
���r c �z � | j D ] }|j � � | j j � y r )r r! r- r. s r r! zFileActor.discard= s) � ����A�
�I�I�K� � �
�
���r c �: � | j j |� y r )r �appendr. s r r1 zFileActor.appendB s � � �
�
���!� r N)r$ r% r& r
r r! r1 r( r r r* r* 4 s � ���
�
r r* c �& � � e Zd Z� fd�Zdd�Z� xZS )�DaskTransactionc � �� ddl }t �| � |� |j � }|j t
d�� j
� | _ y)r r NT)�actor)� distributed�superr
�default_client�submitr* �resultr )r
r r6 �client� __class__s �r r
zDaskTransaction.__init__G s@ �� � �
���� � �+�+�-���]�]�9�D�]�9�@�@�B��
r c �� � |r)| j j � j � n(| j j � j � d| j _ d| _ yr )r r r: r! r r )r
r s r r zDaskTransaction.completeS sJ � � � �J�J� � � � &� &� (� �J�J� � � � '� '� )� �������r r# )r$ r% r& r
r �
__classcell__)r< s @r r3 r3 F s �� �
C�r r3 N)� collectionsr r r* r3 r( r r �<module>r@ s) �� �-� -�` � �$�k� r