diff --git a/fixcloudutils/redis/pub_sub.py b/fixcloudutils/redis/pub_sub.py index c70f970..1d4df7c 100644 --- a/fixcloudutils/redis/pub_sub.py +++ b/fixcloudutils/redis/pub_sub.py @@ -92,7 +92,7 @@ async def read_messages(pubsub: PubSub) -> None: async def stop(self) -> None: await stop_running_task(self.reader) if self.pubsub: - await self.pubsub.aclose() + await self.pubsub.aclose() # type: ignore self.pubsub = None