From 265846e014ff2f7d720c0ab4155e3c9719a586d2 Mon Sep 17 00:00:00 2001 From: Nikita Melkozerov Date: Thu, 26 Oct 2023 17:46:59 +0000 Subject: [PATCH] mypy fix --- fixcloudutils/redis/event_stream.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/fixcloudutils/redis/event_stream.py b/fixcloudutils/redis/event_stream.py index f6d1882..2738ef4 100644 --- a/fixcloudutils/redis/event_stream.py +++ b/fixcloudutils/redis/event_stream.py @@ -201,7 +201,7 @@ async def _handle_stream_messages_parallel(self, messages: List[Any], max_parall Handle messages in parallel in unordered fasion. The number of parallel tasks is limited by max_parallelism. """ - async def handle_and_ack(msg: Any, message_id: StreamIdT): + async def handle_and_ack(msg: Any, message_id: StreamIdT) -> None: await self._handle_single_message(msg) await self.redis.xack(self.stream, self.group, message_id)