U тЭh^ у@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 ·D/var/www/html/venv/lib/python3.8/site-packages/fsspec/transaction.py┌__init__szTransaction.__init__cCs|аб|SйN)┌startйrr r r ┌ __enter__szTransaction.__enter__cCs0|j|dkdН|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__rrrr rr r r r rs rc@s,eZdZddДZddДZddДZddДZd S) ┌ FileActorcCs g|_dSr)rrr r r r5szFileActor.__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)rrrrrrr#r r r r r 4sr cs&eZdZЗfddДZdddДZЗZS)┌DaskTransactioncs4ddl}tГа|б|аб}|jtddНаб|_dS)rrNT)Zactor)┌distributed┌superrZdefault_clientZsubmitr ┌resultr)rrr%┌clientй┌ __class__r r rGszDaskTransaction.__init__TcCs4|r|jабабn|jабабd|j_d|_dSr)rrr'rrr)rrr r r rSs zDaskTransaction.complete)T)rrrrr┌ __classcell__r r r)r r$Fsr$N)┌collectionsrrr r$r r r r ┌s0