/Jf8ddlZddlZddlmZmZmZmZddlmZm Z m Z m Z GddeZ GddeZ Gdd eZdS) N)CompleteMultipartUploadTaskCreateMultipartUploadTaskSubmissionTaskTask)ChunksizeAdjustercalculate_range_parameter get_callbacksget_filtered_dictc leZdZdZdddddddd d d Zgd Zgd ZgdZdZdZ dZ dZ dZ dZ dZdS)CopySubmissionTaskz+Task for submitting tasks to execute a copyIfMatchIfModifiedSince IfNoneMatchIfUnmodifiedSinceSSECustomerKeySSECustomerAlgorithmSSECustomerKeyMD5 RequestPayerExpectedBucketOwner) CopySourceIfMatchCopySourceIfModifiedSinceCopySourceIfNoneMatchCopySourceIfUnmodifiedSinceCopySourceSSECustomerKeyCopySourceSSECustomerAlgorithmCopySourceSSECustomerKeyMD5rr) rrrrrrrrrrrr) rrrrrrrMetadataDirectiveTaggingDirective)rrrrrc|jj|jj}||j}|j}|D]\} } | |jvr| ||j| <|jj di|} |j | d|jj|j kr| |||||dS| |||||dS)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 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 T/home/alex/cs2snipeproduction/venv/lib/python3.11/site-packages/s3transfer/copies.py_submitzCopySubmissionTask._submitPsN,   $ , (,6I>>) #-J!+ 0 0 2 2   uD@@@(CopySourceRangeChecksumAlgorithm) r1r&r?r@ part_numberr'rAr#checksum_algorithm upload_id)rBrCpending_main_kwargs)rOpartsT)rBrCrPrD)r"r$r'r(CREATE_MULTIPART_ARGS_BLACKLISTrErFrr?r@multipart_chunksizeradjust_chunksizer#intmathceilfloatr range_extra_upload_part_argsr_get_transfer_sizegetappend CopyPartTaskr&_extra_complete_multipart_argsr)r0r1r2r3r4r5r$create_multipart_extra_argsr7valcreate_multipart_future part_sizeadjuster num_parts part_futuresrHrMextra_part_argsr#rNcomplete_multipart_extra_argss r:r/z,CopySubmissionTask._submit_multipart_requests$(2 ')##.4466 9 9JE3D@@@58+E2"&"<"C"C  %%)%?$'.$="=     # # . $&&-- +0   Io*/% 2B2BB C C   *?JGG IM22, , K"::$O 2Ka$) 22O- .**a$) D"+!5!9!9:M!N!N    *11$ -1-G&,+4+@&/&6#,=+6*9);$(2D % %()@-    .)-(K(K  ) ) % "))  '%)%?$'.$="? "9)%%        r<ct|trtj|Std|dt |d)NzLExpecting dictionary formatted: {"Bucket": bucket_name, "Key": key} but got z or type .) isinstancedictcopy TypeErrortype)r0r&s r:r%zH   " - -H Ht , , , , , - -r<Nryrzr{r|rr!r<r:rGrG0s)((-----r<rGceZdZdZ ddZdS)r^z)Task to upload a part in a multipart copyNc |jd|||||d|} |D]} | | | dd} | |d}| r2d| }|| dvr| d|||<|S)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)r0r1r&r?r@rOrMr'rAr#rNr9retag part_metadatachecksum_members r:rzCopyPartTask._mainLsL+6* ""      " - -H Ht , , , , ,()&1!%[AA  E);)A)A)C)CEEO(+;"<<<19:J1K#2 o.r<rqrr!r<r:r^r^Is333 888888r<r^)rmrVs3transfer.tasksrrrrs3transfer.utilsrrr r r rGr^r!r<r:rs"  OOOOOOOOd-----T---2;;;;;4;;;;;r<