diff --git a/src/workflows/transport/pika_transport.py b/src/workflows/transport/pika_transport.py index 2a8f5bd..f0d0f36 100644 --- a/src/workflows/transport/pika_transport.py +++ b/src/workflows/transport/pika_transport.py @@ -1484,7 +1484,7 @@ def _run(self): break logger.warning(f"Connection {connection_counter} failed: {e!r}") except BaseException as e: - logger.error(f"Connection failed for unknown reason: {e!r}") + logger.exception(f"Connection failed for unknown reason: {e!r}") self._exc_info = sys.exc_info() break # Make sure our connection is closed before reconnecting