&NjbYSSKrSSKrSSKJr SSKJr SSKJr SSKJ r J r J r J r SSK JrJrJrJr "SS\ 5r"S S \ 5r"S S \ 5r"S S\ 5rg)N) parse_qsl) ClientError)S3CopyFailedError)CompleteMultipartUploadTaskCreateMultipartUploadTaskSubmissionTaskTask)ChunksizeAdjustercalculate_range_parameter get_callbacksget_filtered_dictc \rSrSrSrSSSSSSS S S S . r/S Qr/SQr/SQr/SQr S S /r /SQr S S /r S S /r /SQrSrSrSSjrSrSrSrSrSrSrSrg)CopySubmissionTask"z+Task for submitting tasks to execute a copyIfMatchIfModifiedSince IfNoneMatchIfUnmodifiedSinceSSECustomerKeySSECustomerAlgorithmSSECustomerKeyMD5 RequestPayerExpectedBucketOwner) CopySourceIfMatchCopySourceIfModifiedSinceCopySourceIfNoneMatchCopySourceIfUnmodifiedSinceCopySourceSSECustomerKeyCopySourceSSECustomerAlgorithmCopySourceSSECustomerKeyMD5rr) rrrrrrr rrrrr) rrrrrrr MetadataDirectiveTaggingDirectiveAnnotationDirectiveTagging) CacheControlContentDispositionContentEncodingContentLanguage ContentTypeExpiresMetadata)rrrrr)rrChecksumAlgorithmc 0nSnURRnURRbURRcUR UR 5n UR n U R5H(upXR;dMU U URU 'M* URR"S0U D6n URRU S5 URRU RS55 URU 5nU RS5nURRUR:aUR!XX4U5 gUR#UUUUUUUS9 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 ContentLengthETag VersionId)source_version_id)meta call_argssizeetag)_get_head_object_request_from_copy_source copy_source extra_argsitemsEXTRA_ARGS_TO_HEAD_ARGS_MAPPING source_client head_objectprovide_transfer_sizeprovide_object_etagget_extract_preserved_metadatamultipart_threshold_submit_copy_request_submit_multipart_request)selfclientconfigosutilrequest_executortransfer_futurepreserved_metadatar1r4head_object_requestr9paramvalueresponses N/home/mande/repo/quber/.venv/lib/python3.13/site-packages/s3transfer/copies.py_submitCopySubmissionTask._submitos*  #((22  % % -##((0>>)) #--J!+ 0 0 2 @@@(<  4rScURS5S:XaU$UR5VVs0sHup4X0R;dMX4_M nnnURU5 U$s snnf)Nr!REPLACE)r@r:rupdate)rEr9rKkvresults rPri,CopySubmissionTask._apply_preserved_metadata\sp >>- .) ; '--/ /TQ666 AD/    ()  s A A c[U[5(a[R"U5$[SUS[ U5S35e)NzLExpecting dictionary formatted: {"Bucket": bucket_name, "Key": key} but got z or type .) isinstancedictcopy TypeErrortype)rEr8s rPr7>/ 0F : ++H5((/  $5[ !  .KK   .II  , *EE "//GG   '++M2>J./D(66LL ! #   $** }}"&%56I%J%O%O%Q  " J*9 ;'.7 ?+ !,,:z:  &'?, #!(()9==/:'[) ./0!( $   !   !s#F88 GG  Gr2N) rrrrrrrrrr2rSrPrwrws  2&0PCrSrwc\rSrSrSrSrSrg)r^izTask 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 ) CopySourcerrbytes_transferredNr2) copy_object) rErFr8rVrWr9rXr5callbacks rPrCopyObjectTask._mains8  "s >H "H t ,"rSr2Nrrrrrrrr2rSrPr^r^s (-rSr^c$\rSrSrSrSSjrSrg)rui,z)Task to upload a part in a multipart copyNc UR"SUUUUUS.UD6n UH nU"U S 9 M U S S nUUS.nU (a'SU R 53nUU S ;a U S UUU'U$![aSn U RRS05RS5n USnUSnU S:Xa[ SUSUS 35eeS n A ff=f)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. )rrrr PartNumberErrorCoderrPreconditionFailedzContents of stored object "z " in bucket "z" did not match expected ETag.NrCopyPartResultr/)r/rChecksumr2)upload_part_copyrrOr@rupper)rErFr8rVrWrfrdr9rXr5rerOr error_codesrc_key src_bucketrr6 part_metadatachecksum_members rPrCopyPartTask._main/s'L ..&"&   H("H t ,"()&1!%[A  ();)A)A)C(DEO(+;"<<19:J1K#2 o.- 488@J!%(G$X.J11'1';"",.%%  sA&& C0AB>>Cr2rrr2rSrPruru,s3 ErSru)rrn urllib.parserbotocore.exceptionsrs3transfer.exceptionsrs3transfer.tasksrrrr s3transfer.utilsr r r r rrwr^rur2rSrPrsc "+3 ``F K&AK\-T-2H4HrS