rPjRYddlZddlZddlmZddlmZddlmZddlm Z m Z m Z m Z ddl mZmZmZmZGdde ZGd d e ZGd d e ZGd de Zy)N) parse_qsl) ClientError)S3CopyFailedError)CompleteMultipartUploadTaskCreateMultipartUploadTaskSubmissionTaskTask)ChunksizeAdjustercalculate_range_parameter get_callbacksget_filtered_dictc eZdZdZdddddddd d d Zgd Zgd ZgdZgdZd d gZ gdZ d d gZ d d gZ gdZ dZdZ ddZdZdZdZdZdZdZy)CopySubmissionTaskz+Task for submitting tasks to execute a copyIfMatchIfModifiedSince IfNoneMatchIfUnmodifiedSinceSSECustomerKeySSECustomerAlgorithmSSECustomerKeyMD5 RequestPayerExpectedBucketOwner) CopySourceIfMatchCopySourceIfModifiedSinceCopySourceIfNoneMatchCopySourceIfUnmodifiedSinceCopySourceSSECustomerKeyCopySourceSSECustomerAlgorithmCopySourceSSECustomerKeyMD5rr) rrrrrrrrrrrr) rrrrrrrMetadataDirectiveTaggingDirectiveAnnotationDirectiveTagging) CacheControlContentDispositionContentEncodingContentLanguage ContentTypeExpiresMetadata)rrrrr)rrChecksumAlgorithmc Fi}|jj}d}t|jtr|jj d}|jj |jj|j|j} |j} | jD]&\} } | |jvs| | |j| <(|jjdi| } |jj| d|jj| j d|j!| }|jj |j"kr|j%|||||y|j'|||||||y)a :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 VersionId ContentLengthETag)source_version_id)meta call_args isinstance copy_sourcedictgetsizeetag)_get_head_object_request_from_copy_source extra_argsitemsEXTRA_ARGS_TO_HEAD_ARGS_MAPPING source_client head_objectprovide_transfer_sizeprovide_object_etag_extract_preserved_metadatamultipart_threshold_submit_copy_request_submit_multipart_request)selfclientconfigosutilrequest_executortransfer_futurepreserved_metadatar3r0head_object_requestr;paramvalueresponses V/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/s3transfer/copies.py_submitzCopySubmissionTask._submitos* #((22   i++T 2 ) 5 5 9 9+ F   % % -##((0>>)) #--J!+ 0 0 2  uD@@@(< %  ?rSc|jddk(r|S|jDcic]\}}||jvr||}}}|j||Scc}}w)Nr REPLACE)r7r<rupdate)rFr;rLkvresults rQrhz,CopySubmissionTask._apply_preserved_metadata[ss >>- .) ; #((* 1666 qD   ()  sAct|trtj|Std|dt |d)NzLExpecting dictionary formatted: {"Bucket": bucket_name, "Key": key} but got z or type .)r4r6copy TypeErrortype)rFr5s rQr:zget_object_taggingrrVrWrput_object_tagging) rFrGr3r0rr; directive src_kwargstag_setrr put_kwargss rQrz+CopyCompleteMultipartUploadTask._apply_tagssU)) NN#56 / /   #//9 ,,U3$ 2 J JJ!*; ;'@i--@@c(B  &NN9b1&*AqA&G &&== '*  .FF   &5J{ #!!!/J/'s5Dc z|j}|jddk7ry|jd|jdd}|r||d<i|t|tj }i|t|tj } t|tj} |jjdi|} g} i} | jdgD]}|d}|jjdi| d|i}|j|j||d jd | }|r||d<|r||d < |jdi|| j|| rEt#d |jd |jd| dt%| j'd| y#t $r}|| |<Yd}~d}~wwxYw)Nr"rrrrr- AnnotationsAnnotationNameAnnotationPayload)rrrr ObjectIfMatchz#Failed to copy annotations to s3:///z . Succeeded: z . Failed: z . Errors: r1)r;r7r5r rrrrr>list_object_annotationsget_object_annotationrVrWreadput_object_annotationrs Exceptionrlistkeys)rFrGr3r0rrr;src_base list_kwargsget_kwargs_baseput_passthrough list_response succeededfailed annotationnamepayload_responseres rQrz2CopyCompleteMultipartUploadTask._apply_annotationss3)) >>/ 0F : ++H5((/  $5H[ !  .KK   .II  , *EE H //GG   '++M2> !J./DLy66LL ! #   $** }}"&%5'&$& "J*9 ;'.7 ?+ !,,,:z:  &+ !0 #!(()9==/:'[) ./0!( $   ! t  !s5#F"" F:+F55F:N)rrrrrrrr1rSrQrvrvs  2(0TErSrvceZdZdZdZy)r^zTask to do a nonmultipart copycP|jd|||d||D] }|| y)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_transferredNr1) copy_object) rFrGr5rVrWr;rXr8callbacks rQrzCopyObjectTask._mainsA  "6s >H " -H t , -rSNrrrrrr1rSrQr^r^s (-rSr^ceZdZdZ ddZy)rtz)Task to upload a part in a multipart copyNc | |jd|||||d|} |D] }||  | d d }||d}| r%d| j }|| d vr | d |||<|S#t$rR} | jjdijd} |d}|d}| dk(rt d|d|d d } ~ wwxYw)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/rChecksumr1)upload_part_copyrrPr7rupper)rFrGr5rVrWrercr;rXr8rdrPr error_codesrc_key src_bucketrr9 part_metadatachecksum_members rQrzCopyPartTask._main3s.L .v..&"&   H(" -H t , -()&1!%[A  ();)A)A)C(DEO(+;"<<19:J1K#2 o.- 488@J!%(G$X.J11'1';"",.%%  sA B;)A B66B;rrr1rSrQrtrt0s3 ErSrt)rrm urllib.parserbotocore.exceptionsrs3transfer.exceptionsrs3transfer.tasksrrrr s3transfer.utilsr r r r rrvr^rtr1rSrQrsc "+3 ``F O&AOd-T-2H4HrS