a ’ Àh^ ã@s<ddlmZGdd„dƒZGdd„dƒZGdd„deƒZdS) é)Údequec@s:eZdZdZdd„Zdd„Zdd„Zdd „Zdd d „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 úN/var/www/html/assistant/venv/lib/python3.9/site-packages/fsspec/transaction.pyÚ__init__ szTransaction.__init__cCs | ¡|S©N)Ústart©rr r r Ú __enter__szTransaction.__enter__cCs0|j|dud|jr,d|j_d|j_d|_dS)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.startTcCsB|jr(|j ¡}|r| ¡q| ¡qd|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__r rrr rr r r r rs   rc@s,eZdZdd„Zdd„Zdd„Zdd„Zd S) Ú FileActorcCs g|_dSr )rrr r r r 5szFileActor.__init__cCs"|jD] }| ¡q|j ¡dSr )rrÚclear©rrr r r r8s  zFileActor.commitcCs"|jD] }| ¡q|j ¡dSr )rrr!r"r r r r=s  zFileActor.discardcCs|j |¡dSr )rÚappendr"r r r r#BszFileActor.appendN)rrrr rrr#r r r r r 4sr cs&eZdZ‡fdd„Zddd„Z‡ZS)ÚDaskTransactioncs4ddl}tƒ |¡| ¡}|jtdd ¡|_dS)rrNT)Zactor)Ú distributedÚsuperr Zdefault_clientZsubmitr Úresultr)rrr%Úclient©Ú __class__r r r Gs zDaskTransaction.__init__TcCs4|r|j ¡ ¡n|j ¡ ¡d|j_d|_dSr)rrr'rrr)rrr r r rSs zDaskTransaction.complete)T)rrrr rÚ __classcell__r r r)r r$Fs r$N)Ú collectionsrrr r$r r r r Ús 0