o сРi^ у@s<ddlmZGddДdГZGddДdГZGddДdeГZdS) щ)┌dequec@s:eZdZdZddДZddДZddДZdd ДZdddДZd S)┌TransactionaFilesystem 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 cKs||_tГ|_dS)·O Parameters ---------- fs: FileSystem instance N)┌fsr┌files)┌selfr┌kwargsйr ·a/var/www/html/eduruby.in/lip-sync/lip-sync-env/lib/python3.10/site-packages/fsspec/transaction.py┌__init__szTransaction.__init__cCs|аб|SйN)┌startйrr r r ┌ __enter__szTransaction.__enter__cCs4|j|dudН|jrd|j_d|j_d|_dSdS)z;End transaction and commit, if exit is not due to exceptionN)┌commitF)┌completer┌_intrans┌_transaction)r┌exc_type┌exc_val┌exc_tbr r r ┌__exit__s ¤zTransaction.__exit__cCstГ|_d|j_dS)z&Start a transaction on this FileSystemTN)rrrrrr r r r "szTransaction.startTcCsF|jr|jаб}|r|абn|аб|jsd|j_d|j_d|_dSйz8Finish transaction: commit or discard all deferred filesFN)r┌popleftr┌discardrrr)rr┌fr r r r's √ zTransaction.completeNйT) ┌__name__┌ __module__┌__qualname__┌__doc__rrrr rr r r r rs rc@s,eZdZddДZddДZddДZddДZd S) ┌ FileActorcCs g|_dSr)rrr r r r5s zFileActor.__init__cCє"|jD]}|абq|jабdSr)rr┌clearйrrr r r r8є zFileActor.commitcCr"r)rrr#r$r r r r=r%zFileActor.discardcCs|jа|бdSr)r┌appendr$r r r r&BszFileActor.appendN)rrrrrrr&r r r r r!4s r!cs&eZdZЗfddДZdddДZЗZS)┌DaskTransactioncs4ddl}tГа|б|аб}|jtddНаб|_dS)rrNT)Zactor)┌distributed┌superrZdefault_client┌submitr!┌resultr)rrr(┌clientй┌ __class__r r rGszDaskTransaction.__init__TcCs4|r |jабабn|jабабd|j_d|_dSr)rrr+rrr)rrr r r rSs zDaskTransaction.completer)rrrrr┌ __classcell__r r r-r r'Fsr'N)┌collectionsrrr!r'r r r r ┌s0