diff --git a/janus/__init__.py b/janus/__init__.py index b3a919a..ad145f7 100644 --- a/janus/__init__.py +++ b/janus/__init__.py @@ -138,8 +138,8 @@ def f() -> None: self._sync_not_full.notify() fut = self._loop.run_in_executor(None, f) - fut.add_done_callback(self._pending.discard) # type: ignore - self._pending.add(fut) # type: ignore + fut.add_done_callback(self._pending.discard) + self._pending.add(fut) def _notify_async_not_empty(self, *, threadsafe: bool) -> None: async def f() -> None: