: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 ut
(self, client, request_executor, transfer_future, **kwargs)
| 17 | """Task for submitting tasks to execute an object deletion.""" |
| 18 | |
| 19 | def _submit(self, client, request_executor, transfer_future, **kwargs): |
| 20 | """ |
| 21 | :param client: The client associated with the transfer manager |
| 22 | |
| 23 | :type config: s3transfer.manager.TransferConfig |
| 24 | :param config: The transfer config associated with the transfer |
| 25 | manager |
| 26 | |
| 27 | :type osutil: s3transfer.utils.OSUtil |
| 28 | :param osutil: The os utility associated to the transfer manager |
| 29 | |
| 30 | :type request_executor: s3transfer.futures.BoundedExecutor |
| 31 | :param request_executor: The request executor associated with the |
| 32 | transfer manager |
| 33 | |
| 34 | :type transfer_future: s3transfer.futures.TransferFuture |
| 35 | :param transfer_future: The transfer future associated with the |
| 36 | transfer request that tasks are being submitted for |
| 37 | """ |
| 38 | call_args = transfer_future.meta.call_args |
| 39 | |
| 40 | self._transfer_coordinator.submit( |
| 41 | request_executor, |
| 42 | DeleteObjectTask( |
| 43 | transfer_coordinator=self._transfer_coordinator, |
| 44 | main_kwargs={ |
| 45 | 'client': client, |
| 46 | 'bucket': call_args.bucket, |
| 47 | 'key': call_args.key, |
| 48 | 'extra_args': call_args.extra_args, |
| 49 | }, |
| 50 | is_final=True, |
| 51 | ), |
| 52 | ) |
| 53 | |
| 54 | |
| 55 | class DeleteObjectTask(Task): |
nothing calls this directly
no test coverage detected