Name	Size	Mode	Actions
bandwidth.cpython-313.pyc	17966	0644	editdlrm
compat.cpython-313.pyc	2702	0644	editdlrm
constants.cpython-313.pyc	688	0644	editdlrm
copies.cpython-313.pyc	11143	0644	editdlrm
crt.cpython-313.pyc	42868	0644	editdlrm
delete.cpython-313.pyc	2535	0644	editdlrm
download.cpython-313.pyc	31441	0644	editdlrm
exceptions.cpython-313.pyc	1937	0644	editdlrm
futures.cpython-313.pyc	28704	0644	editdlrm
manager.cpython-313.pyc	26291	0644	editdlrm
processpool.cpython-313.pyc	41416	0644	editdlrm
subscribers.cpython-313.pyc	3673	0644	editdlrm
tasks.cpython-313.pyc	13711	0644	editdlrm
upload.cpython-313.pyc	31474	0644	editdlrm
utils.cpython-313.pyc	36915	0644	editdlrm
__init__.cpython-313.pyc	34343	0644	editdlrm

� ���j�8���SS
KrSS
K
r
SSKJrJrJrJr SSKJrJ r J r Jr "SS\5r"SS\5r "SS \5rg
) �N)�CompleteMultipartUploadTask�CreateMultipartUploadTask�SubmissionTask�Task)�ChunksizeAdjuster�calculate_range_parameter� get_callbacks�get_filtered_dictc �r�\r
SrS
rSrSSSSSSS S SS. r/S Q
r/SQ
r/SQ
rSr Sr SrSrSr SrSrSrg)�CopySubmissionTask�z+Task for submitting tasks to execute a copy�IfMatch�IfModifiedSince�IfNoneMatch�IfUnmodifiedSince�SSECustomerKey�SSECustomerAlgorithm�SSECustomerKeyMD5�RequestPayer�ExpectedBucketOwner) �CopySourceIfMatch�CopySourceIfModifiedSince�CopySourceIfNoneMatch�CopySourceIfUnmodifiedSince�CopySourceSSECustomerKey�CopySourceSSECustomerAlgorithm�CopySourceSSECustomerKeyMD5rr)rrrrrrrrrrrr) rrrrrrr�MetadataDirective�TaggingDirective)rrrrrc�.�URRc�URRnURUR5
nUR nUR 5H(up�X�R;dMU UURU 'M* URR"S0UD
6
nURRUS5
URRUR:aURXX4U5 g
URXX4U5 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�)�meta�size� call_args�)_get_head_object_request_from_copy_source�copy_source� extra_args�items�EXTRA_ARGS_TO_HEAD_ARGS_MAPPING� source_client�head_object�provide_transfer_size�multipart_threshold�_submit_copy_request�_submit_multipart_request)�self�client�config�osutil�request_executor�transfer_futurer%�head_object_requestr(�param�value�responses �D/usr/lib/rads/venv/lib/python3.13/site-packages/s3transfer/copies.py�_submit�CopySubmissionTask._submitPs
��,���$�$�,�(�,�,�6�6�I��>�>��)�)�� � #�-�-�J�!+� 0� 0� 2����@�@�@��(��<�<�U�C��!3�!�.�.�:�:��%��H� � � �6�6���)� ����$�$�v�'A�'A�A��%�%���/� � �*�*���/� �c�.
�URRn[US
5nURR U[URU
URURURURUURRS.SS95 g)N�progress)r2r'�bucket�keyr(� callbacksr$T)�transfer_coordinator�main_kwargs�is_final)r#r%r �_transfer_coordinator�submit�CopyObjectTaskr'rArBr(r$)r1r2r3r4r5r6r%�progress_callbackss r;r/�'CopySubmissionTask._submit_copy_request�s���$�(�(�2�2� �+�?�J�G�� �"�"�)�)���%)�%?�%?�$�#,�#8�#8�'�.�.�$�=�=�"+�"6�"6�!3�+�0�0�5�5��� � r>c��URRn0nURR5Hup�X�R;
dMX�U'M UR R U[UR U
URURUS
.S95n URn[5nURX�RR5n[[R "URR[#U5
-5
5
n /n[%US5n['SU S-5H�nUR)UR5
n[+UUS- U URR5US'UR-UUS- U URR5nURR/S5
nUR1UR R U[3UR U
UR4URURUUUUUS. SU 0
S 955
M� UR7UR5
nUR R U[9UR U
URURUS
.U US .SS95 g) N)r2rArBr()rDrEr@�
�CopySourceRange�ChecksumAlgorithm) r2r'rArB�part_numberr(rCr$�checksum_algorithm� upload_id)rDrE�pending_main_kwargs)rR�partsT)rDrErSrF)r#r%r(r)�CREATE_MULTIPART_ARGS_BLACKLISTrGrHrrArB�multipart_chunksizer�adjust_chunksizer$�int�math�ceil�floatr �range�_extra_upload_part_argsr�_get_transfer_size�get�append�CopyPartTaskr'�_extra_complete_multipart_argsr)r1r2r3r4r5r6r%�create_multipart_extra_argsr8�val�create_multipart_future� part_size�adjuster� num_parts�part_futuresrJrP�extra_part_argsr$rQ�complete_multipart_extra_argss r;r0�,CopySubmissionTask._submit_multipart_request�s���$�(�(�2�2� �')�#�#�.�.�4�4�6�J�E��@�@�@�58�E�2�7�#'�"<�"<�"C�"C��%�%)�%?�%?�$�'�.�.�$�=�=�"=� � �# ���.�.� �$�&���-�-��+�+�0�0� � ���I�I�o�*�*�/�/�%� �2B�B�C� � � ��*�?�J�G�� ��I�
�M�2�K�"�:�:��$�$��O�2K
���a����$�$�)�)� 2�O�-�.��*�*���a����$�$�)�)� �D�"+�!5�!5�!9�!9�:M�!N������*�*�1�1�$� �-1�-G�-G�&,�+4�+@�+@�&/�&6�&6�#,�=�=�+6�*9�);�$(�2D� %�(�)@�-��� �/3�\
)-�(K�(K�� � �) �%� �"�"�)�)��'�%)�%?�%?�$�'�.�.�$�=�=�"?� �"9�)�%�� � r>c��[
U
[5(a[R"U
5
$[S
U
S[ U
5
S35
e
)NzLExpecting dictionary formatted: {"Bucket": bucket_name, "Key": key} but got z or type �
.)� isinstance�dict�copy� TypeError�type)r1r's r;r&�c�,�[
XR5$�
N)r �UPLOAD_PART_COPY_ARGS�r1r(s r;r]�*CopySubmissionTask._extra_upload_part_args
s��!��-G�-G�H�Hr>c�,�[
XR5$rv)r �COMPLETE_MULTIPART_ARGSrxs r;rb�1CopySubmissionTask._extra_complete_multipart_args#
s�� ��-I�-I�J�Jr>c�$�X#S
- :XaXBU
-- $U
$)NrMr")r1rf� part_indexrh�total_transfer_sizes r;r^�%CopySubmissionTask._get_transfer_size&
s$���Q��&�'�y�*@�A�A��r>r"N)�__name__� __module__�__qualname__�__firstlineno__�__doc__r*rwrUr{r<r/r0r&r]rbr^�__static_attributes__r"r>r;rrsj��5�'�%6�!.�':�$4�*@�':�&�4� '�#� �� '�#���<�|
 �4j
 �X�I
�
K
�r>rc
��\r
SrS
rSrSrSrg)rIi0
zTask to do a nonmultipart copyc�L�U
R"SX#US
.UD
6
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 )� CopySource�Bucket�Key�
�bytes_transferredNr")
�copy_object) r1r2r'rArBr(rCr$�callbacks r;�_main�CopyObjectTask._main3
s8�� ��� �"�s� �>H� �"�H��t�,�"r>r"N�r�r�r�r�r�r�r�r"r>r;rIrI0
s ��(�-r>rIc�$�\r
SrS
rSrSSj
rSrg)raiI
z)Task to upload a part in a multipart copyNc ���U
R"SUUUUUS
.UD
6
nUH nU"U S9
M USSn X�S.nU (a%SU R53nX�S;a USUX�'U$)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. )r�r�r��UploadId� PartNumberr��CopyPartResult�ETag)r�r��Checksumr")�upload_part_copy�upper)r1r2r'rArBrRrPr(rCr$rQr:r��etag� part_metadata�checksum_members r;r��CopyPartTask._mainL
s���L
�*�*� �"����"� ��  ��"�H��t�,�"��(�)�&�1��!%�A� �� (�);�)A�)A�)C�(D�E�O��+;�"<�<�19�:J�1K�#�2� �.��r>r"rvr�r"r>r;raraI
s��3� �8r>ra)rqrY�s3transfer.tasksrrrr�s3transfer.utilsrrr r rrIrar"r>r;�r�
sH�


�
��
�
�
�
�O
��O
�d
-�T�
-�2;
�4�;
r>