3SSKrSSKrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSKJ r SS KJ r "S S \5r "S S \5r "SS\5rg)N)Task)SubmissionTask)CreateMultipartUploadTask)CompleteMultipartUploadTask) get_callbacks)calculate_range_parameter)get_filtered_dict)ChunksizeAdjusterc n\rSrSrSrSSSSSSS S S .r/S Qr/S QrS /rSr Sr Sr Sr Sr SrSrSrg)CopySubmissionTaskz+Task for submitting tasks to execute a copyIfMatchIfModifiedSince IfNoneMatchIfUnmodifiedSinceSSECustomerKeySSECustomerAlgorithmSSECustomerKeyMD5 RequestPayer)CopySourceIfMatchCopySourceIfModifiedSinceCopySourceIfNoneMatchCopySourceIfUnmodifiedSinceCopySourceSSECustomerKeyCopySourceSSECustomerAlgorithmCopySourceSSECustomerKeyMD5r) rrrrrrrrrrr) rrrrrrrMetadataDirectiveTaggingDirectivec.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 $lib/third_party/s3transfer/copies.py_submitCopySubmissionTask._submitFs*    $ $ , (,,66I>>))+ #--J!+ 0 0 2 @@@GL(<H J!H t ,"r=r!Nr}r~rrrrrr!r=r:rHrHs (-r=rHc\rSrSrSrSrSrg)r]i$z)Task to upload a part in a multipart copyc dUR"SX#UXVS.UD6n UH n U "U S9 M U SSn XS.$)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 :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. )rrrUploadId PartNumberrCopyPartResultETag)rrr!)upload_part_copy) r0r1r&r@rArOrNr'rBr#r9retags r:rCopyPartTask._main&sY0**F"sF:DF"H t ,"()&188r=r!Nrr!r=r:r]r]$s 39r=r])rmrVs3transfer.tasksrrrrs3transfer.utilsrrr r r rHr]r!r=r:rsL !+68*6..qqh-T-, 94 9r=