o ²Ç 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 úf/var/www/html/construction_image-detection-poc/venv/lib/python3.10/site-packages/fsspec/transaction.pyÚ__init__ s zTransaction.__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 "s zTransaction.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__r rrr rr r r r rs  rc@s,eZdZdd„Zdd„Zdd„Zdd„Zd S) Ú FileActorcCs g|_dSr )rrr r r r 5s 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)rrrr rrr&r r r r r!4s  r!cs&eZdZ‡fdd„Zddd„Z‡ZS)ÚDaskTransactioncs4ddl}tƒ |¡| ¡}|jtdd ¡|_dS)rrNT)Úactor)Ú distributedÚsuperr Údefault_clientÚsubmitr!Ú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.completer)rrrr rÚ __classcell__r r r/r r'Fs  r'N)Ú collectionsrrr!r'r r r r Ús 0