(self, call_args=None)
| 350 | return task_cls(**kwargs) |
| 351 | |
| 352 | def get_transfer_future(self, call_args=None): |
| 353 | return TransferFuture( |
| 354 | meta=TransferMeta(call_args), coordinator=self.transfer_coordinator |
| 355 | ) |
| 356 | |
| 357 | |
| 358 | class BaseSubmissionTaskTest(BaseTaskTest): |
nothing calls this directly
no test coverage detected