Submit
Path:
~
/
/
proc
/
thread-self
/
root
/
proc
/
thread-self
/
root
/
usr
/
lib
/
python2.7
/
site-packages
/
s3transfer
/
File Content:
copies.pyc
� =��Xc @ s� d d l Z d d l Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d e f d � � YZ d e f d � � YZ d e f d � � YZ d S( i����N( t Task( t SubmissionTask( t CreateMultipartUploadTask( t CompleteMultipartUploadTask( t get_callbacks( t calculate_range_parameter( t ChunksizeAdjustert CopySubmissionTaskc B s� e Z d Z i d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6Z d d d d d d d d d d d g Z d d d d d d d d g Z d � Z d � Z d � Z d � Z d � Z d � Z RS( s+ Task for submitting tasks to execute a copyt IfMatcht CopySourceIfMatcht IfModifiedSincet CopySourceIfModifiedSincet IfNoneMatcht CopySourceIfNoneMatcht IfUnmodifiedSincet CopySourceIfUnmodifiedSincet SSECustomerKeyt CopySourceSSECustomerKeyt SSECustomerAlgorithmt CopySourceSSECustomerAlgorithmt SSECustomerKeyMD5t CopySourceSSECustomerKeyMD5t RequestPayert MetadataDirectivec C s� | j j d k r� | j j } | j | j � } | j } x= | j � D]/ \ } } | | j k rF | | | j | <qF qF W| j j | � } | j j | d � n | j j | j k r� | j | | | | | � n | j | | | | | � d S( s� :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 t ContentLengthN( t metat sizet Nonet call_argst) _get_head_object_request_from_copy_sourcet copy_sourcet extra_argst itemst EXTRA_ARGS_TO_HEAD_ARGS_MAPPINGt source_clientt head_objectt provide_transfer_sizet multipart_thresholdt _submit_copy_requestt _submit_multipart_request( t selft clientt configt osutilt request_executort transfer_futureR t head_object_requestR t paramt valuet response( ( s5 /tmp/pip-build-uEGWVr/s3transfer/s3transfer/copies.pyt _submit@ s"