chore: adjustments in mypy checks

nutes-uepb · Oct 2, 2024 · 07dc752 · 07dc752
1 parent c37a152
commit 07dc752
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/amqp_client_python/rabbitmq/async_channel.py b/amqp_client_python/rabbitmq/async_channel.py
@@ -473,6 +473,7 @@ async def rpc_subscribe(
 
         self.queue_bind(queue_name, exchange_name, routing_key)
         if not self.consumers[queue_name]:
+            assert self.ioloop is not None
             registered: Future[bool] = self.ioloop.create_future()
             self.consumers[queue_name] = True
             func = partial(self.on_message, queue_name)