+
    LV-j^	  ã                   óP   € ^ RI Ht  ! R R4      t ! R R4      t ! R R]4      tR# )	é    )Údequec                   óF   a € ] tR t^t o RtR tR tR tR tR	R lt	Rt
V tR# )
ÚTransactionzô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   € Wn         \        4       V n        R# )ú/
Parameters
----------
fs: FileSystem instance
N)Úfsr   Úfiles)Úselfr   Úkwargss   &&,Úc/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/fsspec/transaction.pyÚ__init__ÚTransaction.__init__   s   € ð ŒÜ“WˆŽ
ó    c                ó&   € V P                  4        V # ©N)Ústart©r
   s   &r   Ú	__enter__ÚTransaction.__enter__   s   € Ø�
‰
ŒØˆr   c                ó¨   € V P                  VRJ R7       V P                  '       d,   RV P                  n        RV P                  n        RV n        R# R# )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__ÚTransaction.__exit__   sD   € ð 	�‰˜X¨Ð-ˆÔ.Ø�7�7ˆ7Ø$ˆD�G‰GÔØ#'ˆD�G‰GÔ ØˆDŽGñ r   c                óF   € \        4       V n        RV P                  n        R# )z&Start a transaction on this FileSystemTN)r   r	   r   r   r   s   &r   r   ÚTransaction.start"   s   € ä“WˆŒ
Øˆ�‰Ör   c                ó  € V P                   '       dG   V P                   P                  4       pV'       d   VP                  4        KF  VP                  4        KX  RV P                  n        RV P                  n        RV n        R# ©z8Finish transaction: commit or discard all deferred filesFN)r	   Úpopleftr   Údiscardr   r   r   )r
   r   Úfs   && r   r   ÚTransaction.complete'   sQ   € à�j�jˆjØ—
‘
×"Ñ"Ó$ˆAßØ—‘–
à—	‘	–Ø ˆ�‰ÔØ#ˆ�‰ÔØˆŽr   ©r	   r   N©T)Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__r   r   r   r   r   Ú__static_attributes__Ú__classdictcell__©Ú__classdict__s   @r   r   r      s(   ø‡ € ñòòòò ÷

ò 
r   r   c                   ó8   a € ] tR t^4t o R tR tR tR tRtV t	R# )Ú	FileActorc                ó   € . V n         R # r   ©r	   r   s   &r   r   ÚFileActor.__init__5   s	   € ØˆŽ
r   c                ó€   € V P                    F  pVP                  4        K  	  V P                   P                  4        R # r   )r	   r   Úclear©r
   r&   s   & r   r   ÚFileActor.commit8   s)   € Ø—”ˆAØ�H‰HŽJñ à�
‰
×ÑÖr   c                ó€   € V P                    F  pVP                  4        K  	  V P                   P                  4        R # r   )r	   r%   r9   r:   s   & r   r%   ÚFileActor.discard=   s)   € Ø—”ˆAØ�I‰IŽKñ à�
‰
×ÑÖr   c                ó<   € V P                   P                  V4       R # r   )r	   Úappendr:   s   &&r   r?   ÚFileActor.appendB   s   € Ø�
‰
×Ñ˜!Ör   r6   N)
r*   r+   r,   r-   r   r   r%   r?   r/   r0   r1   s   @r   r4   r4   4   s   ø‡ € òòò
÷
ð r   r4   c                   ó<   a a€ ] tR t^Ft oV 3R ltRR ltRtVtV ;t# )ÚDaskTransactionc                ó¢   <€ ^ RI p\        SV `	  V4       VP                  4       pVP	                  \
        RR7      P                  4       V n        R# )r   NT)Úactor)ÚdistributedÚsuperr   Údefault_clientÚsubmitr4   Úresultr	   )r
   r   rE   ÚclientÚ	__class__s   &&  €r   r   ÚDaskTransaction.__init__G   s@   ø€ ó 	ä‰Ñ˜ÔØ×+Ñ+Ó-ˆØ—]‘]¤9°D�]Ó9×@Ñ@ÓBˆŽ
r   c                óè   € V'       d*   V P                   P                  4       P                  4        M(V P                   P                  4       P                  4        RV P                  n        RV n        R# r#   )r	   r   rI   r%   r   r   )r
   r   s   &&r   r   ÚDaskTransaction.completeS   sJ   € çØ�J‰J×ÑÓ×&Ñ&Õ(à�J‰J×ÑÓ ×'Ñ'Ô)Ø ˆ�‰ÔØˆŽr   r(   r)   )	r*   r+   r,   r-   r   r   r/   r0   Ú__classcell__)rK   r2   s   @@r   rB   rB   F   s   ù‡ € õ
C÷ô r   rB   N)Úcollectionsr   r   r4   rB   © r   r   Ú<module>rR      s)   ðÝ ÷-ñ -÷`ñ ô$�kö r   