add retries to queue consuming, so we retray at least a bit if something happens. Eventually the container should crash though since there do exist unfixable problems sadly.

pyinfra/queue/manager.py

@@ -80,6 +80,7 @@ class QueueManager:
         self.establish_connection()
         return self.channel.is_open
 
+    @retry(exceptions=pika.exceptions.AMQPConnectionError, tries=3, delay=5, jitter=(1, 3), logger=logger)
     def start_consuming(self, message_processor: Callable):
         on_message_callback = self._make_on_message_callback(message_processor)