diff --git a/a_sync/executor.py b/a_sync/executor.py index 57e473ae..d00eaf71 100644 --- a/a_sync/executor.py +++ b/a_sync/executor.py @@ -115,7 +115,7 @@ def submit(self, fn: Callable[P, T], *args: P.args, **kwargs: P.kwargs) -> "asyn fut.set_exception(e) else: fut = wrap_future(self._super_submit(fn, *args, **kwargs)) # type: ignore [assignment] - self._start_debug_daemon(fut, fn, *args, **kwargs) + self._ensure_debug_daemon(fut, fn, *args, **kwargs) return fut def __repr__(self) -> str: