Run the given tasks using the hard timeout in seconds. This is called inside of the forked process.
(self, tasks: List["Task"], hard_timeout: float)
| 27 | raise NotImplementedError("Single tasks are not supported.") |
| 28 | |
| 29 | def run_batch_tasks(self, tasks: List["Task"], hard_timeout: float) -> None: |
| 30 | """ |
| 31 | Run the given tasks using the hard timeout in seconds. |
| 32 | |
| 33 | This is called inside of the forked process. |
| 34 | """ |
| 35 | raise NotImplementedError("Batch tasks are not supported.") |
| 36 | |
| 37 | def run_eager_task(self, task: "Task") -> None: |
| 38 | """ |