diff --git a/aiosched/kernel.py b/aiosched/kernel.py index 03e0478..a886b77 100644 --- a/aiosched/kernel.py +++ b/aiosched/kernel.py @@ -666,6 +666,8 @@ class FIFOKernel: if task is not self.current_task: task.joiners.add(self.current_task) if task.done(): + for joiner in task.joiners: + self.paused.discard(joiner) self.run_ready.extend(task.joiners) def spawn(self, func: Callable[..., Coroutine[Any, Any, Any]], *args, **kwargs):