(self, task, result=None)
| 104 | await hold() |
| 105 | |
| 106 | def _step_task(self, task, result=None): |
| 107 | asyncio.get_event_loop().call_soon_threadsafe(partial(task.step, result)) |
| 108 | |
| 109 | def _on_task_finish(self, task: "Task"): |
| 110 | self._alive_coro_cnt -= 1 |
no outgoing calls
no test coverage detected