+ [mh8^RIt^RIt^RIHtHtHtHt^RIHtH t H t H t !RR]4t !RR]4t !RR ]4tR#) N)CompleteMultipartUploadTaskCreateMultipartUploadTaskSubmissionTaskTask)ChunksizeAdjustercalculate_range_parameter get_callbacksget_filtered_dictca]tRt^toRtRRRRRRRR R R R R RRRRRR/ t.ROt.ROt.ROtRt Rt Rt Rt Rt RtRtRtVtR#)CopySubmissionTaskz+Task for submitting tasks to execute a copyCopySourceIfMatchIfMatchCopySourceIfModifiedSinceIfModifiedSinceCopySourceIfNoneMatch IfNoneMatchCopySourceIfUnmodifiedSinceIfUnmodifiedSinceCopySourceSSECustomerKeySSECustomerKeyCopySourceSSECustomerAlgorithmSSECustomerAlgorithmCopySourceSSECustomerKeyMD5SSECustomerKeyMD5 RequestPayerExpectedBucketOwnerc HVPPfVPPpVPVP4pVP pVP 4F-wrWP9gKV VVPV ,&K/ VPP!R/VBp VPPV R,4VPPVP8dVPWW4V4R#VPWW4V4R#)aj :param client: The client associated with the transfer manager :type config: s3transfer.manager.TransferConfig :param config: The transfer config associated with the transfer manager :type osutil: s3transfer.utils.OSUtil :param osutil: The os utility associated to the transfer manager :type request_executor: s3transfer.futures.BoundedExecutor :param request_executor: The request executor associated with the transfer manager :type transfer_future: s3transfer.futures.TransferFuture :param transfer_future: The transfer future associated with the transfer request that tasks are being submitted for N ContentLength)metasize call_args)_get_head_object_request_from_copy_source copy_source extra_argsitemsEXTRA_ARGS_TO_HEAD_ARGS_MAPPING source_client head_objectprovide_transfer_sizemultipart_threshold_submit_copy_request_submit_multipart_request) selfclientconfigosutilrequest_executortransfer_futurer"head_object_requestr%paramvalueresponses &&&&&& 3/usr/lib/python3/dist-packages/s3transfer/copies.py_submitCopySubmissionTask._submitPs,    $ $ , (,,66I>>)) #--J!+ 0 0 2 @@@(<r?r%r!)r.r/r0r1r2r3r"progress_callbackss&&&&&& r8r,'CopySubmissionTask._submit_copy_requests$((22 +?JG ""))  %)%?%?f!9#8#8i..9== )"6"6!3O0055  r;cvVPPp/pVPP4FwrWP9gKWV&K VP P V\VP RVRVPRVPRV/R74p VPp \4p V PWPP4p \\P !VPP\#V 4, 44p .p\%VR4p\'^V ^,4EFpVP)VP4p\+V V^, V VPP4VR&VP-V V^, V VPP4pVPP/R4pVP1VP P V\3VP RVRVP4RVPRVPR VRVR VR VR V/ R V /R744EK VP7VP4pVP P V\9VP RVRVPRVPRV/R V RV/RR74R#)r/r>r?r%)rArBr=CopySourceRangeChecksumAlgorithmr$ part_numberr@r!checksum_algorithm upload_id)rArBpending_main_kwargspartsT)rArBrOrCN)r r"r%r&CREATE_MULTIPART_ARGS_BLACKLISTrDrErr>r?multipart_chunksizeradjust_chunksizer!intmathceilfloatr range_extra_upload_part_argsr_get_transfer_sizegetappend CopyPartTaskr$_extra_complete_multipart_argsr)r.r/r0r1r2r3r"create_multipart_extra_argsr5valcreate_multipart_future part_sizeadjuster num_parts part_futuresrGrLextra_part_argsr!rMcomplete_multipart_extra_argss&&&&&& r8r-,CopySubmissionTask._submit_multipart_requests$((22 ')##..446JE@@@58E27#'"<"<"C"C  %%)%?%?fi..9== "=   # .. $&-- ++00  IIo**//% 2BB C  *?JG IM2K"::$$O 2Ka$$)) 2O- .**a$$)) D"+!5!5!9!9:M!N    **11$ -1-G-G$f)9+@+@$i&6&6!9==);(/');"D02D %()@- /3\)-(K(K  ) % ""))  '%)%?%?fi..9== "?  !8\%  r;c\V\4'd\P!V4#\RV R\ V4 R24h)zLExpecting dictionary formatted: {"Bucket": bucket_name, "Key": key} but got z or type .) isinstancedictcopy TypeErrortype)r.r$s&&r8r#W#^, 8XdWBV,, #V#)r)r.rb part_indexrdtotal_transfer_sizes&&&&&r8rZ%CopySubmissionTask._get_transfer_size&s$ Q &'y*@A Ar;rN) r rrrrrrrrrrr) r rrrrrrMetadataDirectiveTaggingDirective)rrrrr)__name__ __module__ __qualname____firstlineno____doc__r'rsrQrwr9r,r-r#rYr^rZ__static_attributes____classdictcell__ __classdict__s@r8r r s5 Y#%6%':"$4(*@%':4 '#  '#<| 4j XI Kr;r c*a]tRtRtoRtRtRtVtR#)rFi0zTask to do a nonmultipart copyc  ZVP!RRVRVRV/VBVF pV!VR7K R#)a :param client: The client to use when calling PutObject :param copy_source: The CopySource parameter to use :param bucket: The name of the bucket to copy to :param key: The name of the key to copy to :param extra_args: A dictionary of any extra arguments that may be used in the upload. :param callbacks: List of callbacks to call after copy :param size: The size of the transfer. This value is passed into the callbacks CopySourceBucketKeybytes_transferredNr) copy_object) r.r/r$r>r?r%r@r!callbacks &&&&&&&& r8_mainCopyObjectTask._main3sF  " +1 7: >H "H t ,"r;rNrrrrrrrrrs@r8rFrF0s(--r;rFc.a]tRtRtoRtRRltRtVtR#)r]iIz)Task to upload a part in a multipart copyNc  VP!R RVRVRVRVRV/VBp VF p V !V R7K V R,R,p RV RV/pV 'd3R V P4 2pWR,9dV R,V,W&V#) a :param client: The client to use when calling PutObject :param copy_source: The CopySource parameter to use :param bucket: The name of the bucket to upload to :param key: The name of the key to upload to :param upload_id: The id of the upload :param part_number: The number representing the part of the multipart upload :param extra_args: A dictionary of any extra arguments that may be used in the upload. :param callbacks: List of callbacks to call after copy part :param size: The size of the transfer. This value is passed into the callbacks :param checksum_algorithm: The algorithm that was used to create the multipart upload :rtype: dict :returns: A dictionary representing a part:: {'Etag': etag_value, 'PartNumber': part_number} This value can be appended to a list to be used to complete the multipart upload. If a checksum is in the response, it will also be included. rrrUploadId PartNumberrCopyPartResultETagChecksumr)upload_part_copyupper)r.r/r$r>r?rNrLr%r@r!rMr7retag part_metadatachecksum_members&&&&&&&&&&& r8rCopyPartTask._mainLsL** "     #    "H t ,"()&1|[A  ();)A)A)C(DEO+;"<<19:J1K#2 .r;rrrrrs@r8r]r]Is388r;r])rmrUs3transfer.tasksrrrrs3transfer.utilsrrr r r rFr]rr;r8rsH  OOd-T-2;4;r;