TQg8SSKrSSKrSSKJrJrJrJr SSKJrJ r J r J r "SS\5r "SS\5r "SS \5rg) N)CompleteMultipartUploadTaskCreateMultipartUploadTaskSubmissionTaskTask)ChunksizeAdjustercalculate_range_parameter get_callbacksget_filtered_dictc r\rSrSrSrSSSSSSS S S S . r/S Qr/SQr/SQrSr Sr Sr Sr Sr SrSrSrg)CopySubmissionTaskz+Task for submitting tasks to execute a copyIfMatchIfModifiedSince IfNoneMatchIfUnmodifiedSinceSSECustomerKeySSECustomerAlgorithmSSECustomerKeyMD5 RequestPayerExpectedBucketOwner) CopySourceIfMatchCopySourceIfModifiedSinceCopySourceIfNoneMatchCopySourceIfUnmodifiedSinceCopySourceSSECustomerKeyCopySourceSSECustomerAlgorithmCopySourceSSECustomerKeyMD5rr) rrrrrrrrrrrr) rrrrrrrMetadataDirectiveTaggingDirective)rrrrrc.URRcURRnURUR5nUR nUR 5H(upXR;dMU UURU 'M* URR"S0UD6n URRU S5 URRUR:aURXX4U5 gURXX4U5 g)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 @@@(<cURRn0nURR5HupXR;dMXU'M UR R U[UR UURURUS.S95n URn [5n U RXRR5n [[R "URR[#U 5- 55n /n[%US5n['SU S-5HnUR)UR5n[+U US- U URR5US'UR-U US- U URR5nURR/S5nUR1UR R U[3UR UUR4URURUUUUUS. SU 0S 955 M UR7UR5nUR R U[9UR UURURUS.U US .S S 95 g) N)r2rArBr()rDrEr@CopySourceRangeChecksumAlgorithm) r2r'rArB part_numberr(rCr$checksum_algorithm upload_id)rDrEpending_main_kwargs)rRpartsT)rDrErSrF)r#r%r(r)CREATE_MULTIPART_ARGS_BLACKLISTrGrHrrArBmultipart_chunksizeradjust_chunksizer$intmathceilfloatr range_extra_upload_part_argsr_get_transfer_sizegetappend CopyPartTaskr'_extra_complete_multipart_argsr)r1r2r3r4r5r6r%create_multipart_extra_argsr8valcreate_multipart_future part_sizeadjuster num_parts part_futuresrJrPextra_part_argsr$rQcomplete_multipart_extra_argss r;r0,CopySubmissionTask._submit_multipart_requests$((22 ')##..446JE@@@58E27#'"<"<"C"C  %%)%?%?$'..$=="=   # .. $&-- ++00  IIo**//% 2BB C  *?JG IM2K"::$$O 2Ka$$)) 2O- .**a$$)) D"+!5!5!9!9:M!N    **11$ -1-G-G&,+4+@+@&/&6&6#,==+6*9);$(2D %()@- /3\)-(K(K  ) % ""))  '%)%?%?$'..$=="? "9)%  r>c[U[5(a[R"U5$[SUS[ U5S35e)NzLExpecting dictionary formatted: {"Bucket": bucket_name, "Key": key} but got z or type .) isinstancedictcopy TypeErrortype)r1r's r;r&c,[XR5$N)r UPLOAD_PART_COPY_ARGSr1r(s r;r]*CopySubmissionTask._extra_upload_part_argss!-G-GHHr>c,[XR5$rv)r COMPLETE_MULTIPART_ARGSrxs r;rb1CopySubmissionTask._extra_complete_multipart_args#s -I-IJJr>c$X#S- :XaXBU-- $U$)NrMr")r1rf part_indexrhtotal_transfer_sizes r;r^%CopySubmissionTask._get_transfer_size&s$ Q &'y*@A Ar>r"N)__name__ __module__ __qualname____firstlineno____doc__r*rwrUr{r<r/r0r&r]rbr^__static_attributes__r"r>r;r r sj5'%6!.':$4*@':&4 '#  '#<| 4j XI Kr>r c\rSrSrSrSrSrg)rIi0zTask to do a nonmultipart copycLUR"SX#US.UD6 UH nU"US9 M g)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) r1r2r'rArBr(rCr$callbacks r;_mainCopyObjectTask._main3s8  "s >H "H t ,"r>r"Nrrrrrrrr"r>r;rIrI0s (-r>rIc$\rSrSrSrSSjrSrg)raiIz)Task to upload a part in a multipart copyNc UR"SUUUUUS.UD6n UH n U "U S9 M U SSn XS.nU (a%SU R53nXS;a U SUX'U$)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 PartNumberrCopyPartResultETag)rrChecksumr")upload_part_copyupper)r1r2r'rArBrRrPr(rCr$rQr:retag part_metadatachecksum_members r;rCopyPartTask._mainLsL** ""    "H t ,"()&1!%A  ();)A)A)C(DEO+;"<<19:J1K#2 .r>r"rvrr"r>r;raraIs3 8r>ra)rqrYs3transfer.tasksrrrrs3transfer.utilsrrr r r rIrar"r>r;rsH  OOd-T-2;4;r>