MCPcopy Create free account
hub / github.com/aws/aws-cli / _submit_upload_request

Method _submit_upload_request

awscli/s3transfer/upload.py:624–661  ·  view source on GitHub ↗
(
        self,
        client,
        config,
        osutil,
        request_executor,
        transfer_future,
        upload_input_manager,
    )

Source from the content-addressed store, hash-verified

622 )
623
624 def _submit_upload_request(
625 self,
626 client,
627 config,
628 osutil,
629 request_executor,
630 transfer_future,
631 upload_input_manager,
632 ):
633 call_args = transfer_future.meta.call_args
634
635 put_object_extra_args = self._extra_put_object_args(
636 call_args.extra_args
637 )
638
639 # Get any tags that need to be associated to the put object task
640 put_object_tag = self._get_upload_task_tag(
641 upload_input_manager, 'put_object'
642 )
643
644 # Submit the request of a single upload.
645 self._transfer_coordinator.submit(
646 request_executor,
647 PutObjectTask(
648 transfer_coordinator=self._transfer_coordinator,
649 main_kwargs={
650 'client': client,
651 'fileobj': upload_input_manager.get_put_object_body(
652 transfer_future
653 ),
654 'bucket': call_args.bucket,
655 'key': call_args.key,
656 'extra_args': put_object_extra_args,
657 },
658 is_final=True,
659 ),
660 tag=put_object_tag,
661 )
662
663 def _submit_multipart_request(
664 self,

Callers 1

_submitMethod · 0.95

Calls 5

_get_upload_task_tagMethod · 0.95
PutObjectTaskClass · 0.85
submitMethod · 0.45
get_put_object_bodyMethod · 0.45

Tested by

no test coverage detected