/usr/lib/rads/venv/lib/python3.13/site-packages/s3transfer/__pycache__
Edit: /usr/lib/rads/venv/lib/python3.13/site-packages/s3transfer/__pycache__/futures.cpython-313.pyc (28704B)
j2U S SK r S SKrS SKrS SKrS SKJr S SKJr S SKJ r S SK
J r J r S SK
JrJr S SKJr \R& " \5 r " S S
5 r " S S 5 r " S
S\5 r " S S\5 r " S S5 r " S S5 r " S S5 r " S S5 r " S S\ 5 r " S S 5 r \" S S /5 r \ " S 5 r!\ " S 5 r"g! \ a S r Nf = f)! N)
namedtuple)futures)MAXINT)CancelledErrorTransferNotDoneError)FunctionContainer
TaskSemaphore) get_contextc g N r
E/usr/lib/rads/venv/lib/python3.13/site-packages/s3transfer/futures.pyr
r
s r c 6 \ rS rSr\S 5 rS rS rS rSr g)BaseTransferFuture# c [ S5 e)z-The metadata associated to the TransferFuturemetaNotImplementedErrorselfs r r BaseTransferFuture.meta$ s "&))r c [ S5 e)z]Determines if a TransferFuture has completed
:returns: True if completed. False, otherwise.
zdone()r r s r doneBaseTransferFuture.done) s
"(++r c [ S5 e)Waits until TransferFuture is done and returns the result
If the TransferFuture succeeded, it will return the result. If the
TransferFuture failed, it will raise the exception associated to the
failure.
zresult()r r s r resultBaseTransferFuture.result0 s "*--r c [ S5 e)z6Cancels the request associated with the TransferFuturezcancel()r r s r cancelBaseTransferFuture.cancel9 s
!*--r r
N)
__name__
__module__ __qualname____firstlineno__propertyr r r r" __static_attributes__r
r r r r # s#
* *,..r r c D \ rS rSr\S 5 r\S 5 r\S 5 rSrg)BaseTransferMeta> c [ S5 e)*The call args used in the transfer request call_argsr r s r r/ BaseTransferMeta.call_args? s "+..r c [ S5 e) The unique id of the transfer transfer_idr r s r r3 BaseTransferMeta.transfer_idD s "-00r c [ S5 e).A dictionary that requesters can store data in user_contextr r s r r7 BaseTransferMeta.user_contextI s ".11r r
N) r$ r% r& r' r( r/ r3 r7 r) r
r r r+ r+ > s<
/ / 1 1 2 2r r+ c F \ rS rSrS
S jr\S 5 rS rS rS r S r
S r g) TransferFutureO Nc f Xl Uc [ 5 U l X l Uc [ 5 U l gg)aJ The future associated to a submitted transfer request
:type meta: TransferMeta
:param meta: The metadata associated to the request. This object
is visible to the requester.
:type coordinator: TransferCoordinator
:param coordinator: The coordinator associated to the request. This
object is not visible to the requester.
N)_meta TransferMeta _coordinatorTransferCoordinator)r r coordinators r __init__TransferFuture.__init__P s3
<% DJ ' 3 5D r c U R $ r )r= r s r r TransferFuture.metac s zzr c 6 U R R 5 $ r )r? r r s r r TransferFuture.doneg s %%''r c U R R 5 $ ! [ a nU R 5 UeS nAff = fr )r? r KeyboardInterruptr" )r es r r TransferFuture.resultj s< $$++- - KKMG s
=8=c 8 U R R 5 g r )r? r" r s r r" TransferFuture.cancelt s "r c x U R 5 ( d [ S5 eU R R USS9 g)z!Sets the exception on the future.z?set_exception can only be called once the transfer is complete.T)overrideN)r r r?
set_exception)r exceptions r rP TransferFuture.set_exceptionw s: yy{{&
'' D'Ar )r? r= NN) r$ r% r& r' rB r( r r r r" rP r) r
r r r: r: O s0 6& (#Br r: c ~ \ rS rSrSrS
S jr\S 5 r\S 5 r\S 5 r \S 5 r
\S 5 r S
r S r
S rg)r> z'Holds metadata about the TransferFutureNc F Xl X l S U l 0 U l S U l g r )
_call_args _transfer_id_size
_user_context_etag)r r/ r3 s r rB TransferMeta.__init__ s# # '
r c U R $ )r. )rW r s r r/ TransferMeta.call_args s r c U R $ )r2 )rX r s r r3 TransferMeta.transfer_id s r c U R $ )z)The size of the transfer request if knownrY r s r sizeTransferMeta.size zzr c U R $ )r6 )rZ r s r r7 TransferMeta.user_context s !!!r c U R $ )z@The etag of the stored object for validating multipart downloadsr[ r s r etagTransferMeta.etag re r c Xl g)zA method to provide the size of a transfer request
By providing this value, the TransferManager will not try to
call HeadObject or use the use OS to determine the size of the
transfer.
Nrb )r rc s r provide_transfer_size"TransferMeta.provide_transfer_size
r c Xl g)zA method to provide the etag of a transfer request
By providing this value, the TransferManager will validate
multipart downloads by supplying an IfMatch parameter with
the etag as the value to GetObject requests.
Nri )r rj s r provide_object_etag TransferMeta.provide_object_etag ro r )rW r[ rY rX rZ rS )r$ r% r& r' __doc__rB r( r/ r3 rc r7 rj rm rq r) r
r r r> r> sx 1 ! ! " " r r> c \ rS rSrSrS S jrS r\S 5 r\S 5 r \S 5 r
\S 5 r S
r S S jr
S rS
\4S jrS rS rS rS S jrS rS rS rS rS rS rS rS r S r S r S r g) r@ z*A helper class for managing TransferFutureNc x Xl SU l S U l S U l [ 5 U l / U l / U l [ R " 5 U l
[ R " 5 U l [ R " 5 U l
[ R " 5 U l [ R " 5 U l g )N not-started)r3 _status_result
_exceptionset_associated_futures_failure_cleanups_done_callbacks threadingEvent _done_eventLock_lock_associated_futures_lock_done_callbacks_lock_failure_cleanups_lock)r r3 s r rB TransferCoordinator.__init__ s &$ #&5 !# ! $??, ^^%
(1(8%$-NN$4!&/nn&6#r c N U R R SU R S3$ )Nz
(transfer_id=)) __class__r$ r3 r s r __repr__ TransferCoordinator.__repr__ s' ..))*-8H8H7IKKr c U R $ r )rz r s r rQ TransferCoordinator.exception s r c U R [ R " U R 5 sSSS5 $ ! , ( d f g= f)zThe list of futures associated to the inprogress TransferFuture
Once the transfer finishes this list becomes empty as the transfer
is considered done and there should be no running futures left.
N)r copyr| r s r associated_futures&TransferCoordinator.associated_futures s-
*
* 99T 5 56 +
*
*s 7
Ac U R $ )z;The list of callbacks to call when the TransferFuture fails)r} r s r failure_cleanups$TransferCoordinator.failure_cleanups s %%%r c U R $ )a The status of the TransferFuture
The currently supported states are:
* not-started - Has yet to start. If in this state, a transfer
can be canceled immediately and nothing will happen.
* queued - SubmissionTask is about to submit tasks
* running - Is inprogress. In-progress as of now means that
the SubmissionTask that runs the transfer is being executed. So
there is no guarantee any transfer requests had been made to
S3 if this state is reached.
* cancelled - Was cancelled
* failed - An exception other than CancelledError was thrown
* success - No exceptions were thrown and is done.
)rx r s r statusTransferCoordinator.status s ||r c x U R SU l Xl SU l SSS5 g! , ( d f g= f)a Set a result for the TransferFuture
Implies that the TransferFuture succeeded. This will always set a
result because it is invoked on the final task where there is only
ever one final task and it is ran at the very end of a transfer
process. So if a result is being set for this final task, the transfer
succeeded even if something came a long and canceled the transfer
on the final task.
Nsuccess)r rz ry rx r r s r
set_result TransferCoordinator.set_result s( ZZ "DO!L$DL ZZs +
9c U R U R 5 ( a U( a
Xl SU l SSS5 g! , ( d f g= f)zSet an exception for the TransferFuture
Implies the TransferFuture failed.
:param exception: The exception that cause the transfer to fail.
:param override: If True, override any existing state.
failedN)r r rz rx )r rQ rO s r rP !TransferCoordinator.set_exception s. ZZ99;;("+ ' ZZs *A
Ac U R R [ 5 U R ( a U R eU R $ )r )r waitr rz ry r s r r TransferCoordinator.result s5
f% ??// !||r c $ U R U R 5 ( dU Sn[ R SX5 U" U5 U l U R
S:X a SnSU l U( a U R
5 SSS5 g! , ( d f g= f)zCancels the TransferFuture
:param msg: The message to attach to the cancellation
:param exc_type: The type of exception to set for the cancellation
Fz%s cancel(%s) calledrw T cancelledN)r r loggerdebugrz rx
announce_done)r msgexc_typeshould_announce_dones r r" TransferCoordinator.cancel" sh ZZ99;;',$ 3T?"*3-<<=0+/( * '&&( ZZs A+B
Bc & U R S5 g)z+Sets the TransferFutrue's status to runningqueuedN _transition_to_non_done_stater s r set_status_to_queued(TransferCoordinator.set_status_to_queued3 s **84r c & U R S5 g)z+Sets the TransferFuture's status to runningrunningNr r s r set_status_to_running)TransferCoordinator.set_status_to_running7 s **95r c U R U R 5 ( a [ SU R SU S35 eXl S S S 5 g ! , ( d f g = f)Nz%Unable to transition from done state z to non-done state .)r r RuntimeErrorr rx )r
desired_states r r 1TransferCoordinator._transition_to_non_done_state; sO
ZZyy{{";DKK= I *O1. )L
ZZs 8A
A c [ R SU SU SU R S35 UR X#S9nU R U5 UR [
U R U5 5 U$ )a Submits a task to a provided executor
:type executor: s3transfer.futures.BoundedExecutor
:param executor: The executor to submit the callable to
:type task: s3transfer.tasks.Task
:param task: The task to submit to the executor
:type tag: s3transfer.futures.TaskTag
:param tag: A tag to associate to the submitted task
:rtype: concurrent.futures.Future
:returns: A future representing the submitted task
zSubmitting task z
to executor z for transfer request: r )tag)r r r3 submitadd_associated_futureadd_done_callbackr remove_associated_future)r executortaskr futures r r TransferCoordinator.submitD sy tfM(;RSWScScRdde f
/
""6* d ; ;V D
r c U R S; $ )zDetermines if a TransferFuture has completed
:returns: False if status is equal to 'failed', 'cancelled', or
'success'. True, otherwise
)r r r )r r s r r TransferCoordinator.done_ s {{ @@@r c U R U R R U5 SSS5 g! , ( d f g= f)z6Adds a future to be associated with the TransferFutureN)r r| addr r s r r )TransferCoordinator.add_associated_futureg s+
*
* $ $ ( ( 0 +
*
* 2
A c U R U R R U5 SSS5 g! , ( d f g= f)z4Removes a future's association to the TransferFutureN)r r| remover s r r ,TransferCoordinator.remove_associated_futurel s+
*
* $ $ + +F 3 +
*
*r c U R U R R [ U/UQ70 UD65 SSS5 g! , ( d f g= f)z7Add a done callback to be invoked when transfer is doneN)r r~ appendr r functionargskwargss r r %TransferCoordinator.add_done_callbackq s=
&
& ' '!(
T" 5 $ r r
)future_passed_to_callbackfns r
done_callback7ExecutorFuture.add_done_callback..done_callback s
4Kr N)r r )r r r s ` r r ExecutorFuture.add_done_callback
s
&&}5r c 6 U R R 5 $ r )r r r s r r ExecutorFuture.done s || ""r r N) r$ r% r& r' rB r r r r) r
r r r r s %6 #r r c 2 \ rS rSrSrSS jrS rS S jrSrg)
BaseExecutori zABase Executor class implementation needed to work with s3transferNc g r r
)r r s r rB BaseExecutor.__init__! r c [ S5 e)Nzsubmit()r )r r r r s r r BaseExecutor.submit$ s
!*--r c [ S5 e)Nz
shutdown()r r s r r BaseExecutor.shutdown' s
!,//r r
r r ) r$ r% r& r' rs rB r r r) r
r r r r s K
.0r r c ( \ rS rSrSrS rSS jrSrg)NonThreadedExecutori+ z@A drop-in replacement non-threaded version of ThreadPoolExecutorc [ 5 n U" U0 UD6nUR U5 U$ ! [ aG [ R " 5 SS u pg[
R
SUUU5 UR Xg5 U$ f = f)N z0Setting exception for %s to %s with traceback %s)NonThreadedExecutorFuturer r sysr r r set_exception_info)r r r r r r rJ tbs r r NonThreadedExecutor.submit. s *, -((F f %
-LLN12&EA LLB
% %a ,
-s ' A
A87A8c g r r
r s r r NonThreadedExecutor.shutdown> r! r r
Nr )r$ r% r& r' rs r r r) r
r r r' r' + s J
r r' c L \ rS rSrSrS rS rS rS
S jrS r S r
S
r S r S r
g)r* iB zThe Future returned from NonThreadedExecutor
Note that this future is **not** thread-safe as it is being used
from the context of a non-threaded environment.
c J S U l S U l S U l SU l / U l g )NF)ry rz
_traceback_doner~ r s r rB "NonThreadedExecutorFuture.__init__I s&
! r c 0 Xl U R 5 g r )ry _set_doner s r r $NonThreadedExecutorFuture.set_resultP s r c < Xl X l U R 5 g r )rz r3 r7 )r rQ tracebacks r r, ,NonThreadedExecutorFuture.set_exception_infoT s ## r Nc U R ( a% U R R U R 5 eU R $ r )rz with_tracebackr3 ry )r timeouts r r NonThreadedExecutorFuture.resultY s, ??//00 A A||r c h SU l U R H nU R U5 M / U l g r
)r4 r~ _invoke_done_callbackr r s r r7 #NonThreadedExecutorFuture._set_done^ s/
! 1 1M & &} 5 2 ! r c U" U 5 $ r r
rB s r rA /NonThreadedExecutorFuture._invoke_done_callbackd s
T""r c U R $ r )r4 r s r r NonThreadedExecutorFuture.doneg s zzr c U R ( a U R U5 g U R R U5 g r )r4 rA r~ r )r r s r r +NonThreadedExecutorFuture.add_done_callbackj s+ :: & &r * ' ' +r )r4 r~ rz ry r3 r )r$ r% r& r' rs rB r r, r r7 rA r r r) r
r r r* r* B s/ "
" #,r r* TaskTagnamein_memory_uploadin_memory_download)#r loggingr+ r collectionsr
concurrentr s3transfer.compatr s3transfer.exceptionsr r s3transfer.utilsr r botocore.contextr
ImportError getLoggerr$ r r r+ r: r> r@ r r r r' r* rJ IN_MEMORY_UPLOAD_TAGIN_MEMORY_DOWNLOAD_TAGr
r r rY s
" $ F =,
8 $. .62 2"/B' /Bd3# 3loL oLdM& M&`"# "#J
0
0
,
.,, ,,^ Y
) 12 !56 u s C CC