(
self,
client,
config,
osutil,
request_executor,
transfer_future,
upload_input_manager,
)
| 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, |
no test coverage detected