i<ddlZddlZddlmZddlmZddlmZmZm Z m Z ddl m Z m Z mZmZGdde ZGdd e ZGd d e Zy) N) ClientError)S3CopyFailedError)CompleteMultipartUploadTaskCreateMultipartUploadTaskSubmissionTaskTask)ChunksizeAdjustercalculate_range_parameter get_callbacksget_filtered_dictc jeZdZdZdddddddd d d Zgd Zgd ZgdZdZdZ dZ dZ dZ dZ dZy)CopySubmissionTaskz+Task for submitting tasks to execute a copyIfMatchIfModifiedSince IfNoneMatchIfUnmodifiedSinceSSECustomerKeySSECustomerAlgorithmSSECustomerKeyMD5 RequestPayerExpectedBucketOwner) CopySourceIfMatchCopySourceIfModifiedSinceCopySourceIfNoneMatchCopySourceIfUnmodifiedSinceCopySourceSSECustomerKeyCopySourceSSECustomerAlgorithmCopySourceSSECustomerKeyMD5rr) rrrrrrrrrrrr) rrrrrrrMetadataDirectiveTaggingDirective)rrrrrc|jj|jj|jj}|j |j }|j }|jD]&\} } | |jvs| ||j| <(|jjdi|} |jj| d|jj| jd|jj|jkr|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 ContentLengthETag)metasizeetag call_args)_get_head_object_request_from_copy_source copy_source extra_argsitemsEXTRA_ARGS_TO_HEAD_ARGS_MAPPING source_client head_objectprovide_transfer_sizeprovide_object_etaggetmultipart_threshold_submit_copy_request_submit_multipart_request) selfclientconfigosutilrequest_executortransfer_futurer(head_object_requestr+paramvalueresponses h/var/www/acinvestment.org/public_html/aci/backend/venv/lib/python3.12/site-packages/s3transfer/copies.py_submitzCopySubmissionTask._submitSs^,  % % -##((0(,,66I>>)) #--J!+ 0 0 2  uD@@@(<H " -H t , -rBNr~rrrrr$rBr@rMrM<s (-rBrMceZdZdZ ddZy)rcz)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. )rrrUploadId PartNumberErrorCoderrPreconditionFailedzContents of stored object "z " in bucket "z" did not match expected ETag.NrCopyPartResultr#)r#rChecksumr$)upload_part_copyrr?r2rupper)r6r7r*rErFrUrSr+rGr&rTr?e error_codesrc_key src_bucketrr' part_metadatachecksum_members r@rzCopyPartTask._mainXs.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;rvrr$rBr@rcrcUs3 ErBrc)rrr\botocore.exceptionsrs3transfer.exceptionsrs3transfer.tasksrrrrs3transfer.utilsr r r r rrMrcr$rBr@rsP +3 XXv-T-2H4HrB