(self, task: Callable[..., T], *args, **kwargs)
| 94 | |
| 95 | @abc.abstractmethod |
| 96 | def submit_sync(self, task: Callable[..., T], *args, **kwargs) -> List[T]: |
| 97 | raise NotImplementedError() |
| 98 | |
| 99 | @abc.abstractmethod |
| 100 | def shutdown(self, wait=True): |
no outgoing calls
no test coverage detected