The submission method to be implemented :type transfer_future: s3transfer.futures.TransferFuture :param transfer_future: The transfer future associated with the transfer request that tasks are being submitted for :param kwargs: Any additional keyword arguments y
(self, transfer_future, **kwargs)
| 290 | self._transfer_coordinator.announce_done() |
| 291 | |
| 292 | def _submit(self, transfer_future, **kwargs): |
| 293 | """The submission method to be implemented |
| 294 | |
| 295 | :type transfer_future: s3transfer.futures.TransferFuture |
| 296 | :param transfer_future: The transfer future associated with the |
| 297 | transfer request that tasks are being submitted for |
| 298 | |
| 299 | :param kwargs: Any additional keyword arguments you want to be passed |
| 300 | in |
| 301 | """ |
| 302 | raise NotImplementedError('_submit() must be implemented') |
| 303 | |
| 304 | def _wait_for_all_submitted_futures_to_complete(self): |
| 305 | # We want to wait for all futures that were submitted to |