make kombu DNS failures louder in the logs

ansible · Sep 30, 2019 · ecb9682 · ecb9682
1 parent b858001
commit ecb9682
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/awx/main/dispatch/kombu.py b/awx/main/dispatch/kombu.py
@@ -40,3 +40,12 @@ class _Transport(pyamqp.Transport):
             Connection = _Connection
 
         self.transport_cls = _Transport
+
+    def ensure_connection(self, errback=None, **kwargs):
+        if errback is None:
+            # print a verbose error message so things like DNS failures to the
+            # RabbitMQ hostname are surfaced
+            errback = lambda exc, interval: logger.exception(exc)
+        return super(Connection, self).ensure_connection(
+            errback=errback, **kwargs
+        )