Fix to the logging setup in the listener

LCOGT · Aug 10, 2023 · 5bbd901 · 5bbd901
1 parent abebe1c
commit 5bbd901
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/banzai/main.py b/banzai/main.py
@@ -186,7 +186,7 @@ def run_realtime_pipeline():
 def start_listener(runtime_context):
     # Need to keep the amqp logger level at least as high as INFO,
     # or else it send heartbeat check messages every second
-    logging.getLogger('amqp').setLevel(max(logger.level, getattr(logging, 'INFO')))
+    logging.getLogger('amqp').setLevel(max(logging.getLogger().level, getattr(logging, 'INFO')))
     logger.info('Starting pipeline listener')
 
     fits_exchange = Exchange(runtime_context.FITS_EXCHANGE, type='fanout')