Raised the level of logging for celery.

LCOGT · Aug 11, 2023 · 22f87ce · 22f87ce
1 parent d1364ec
commit 22f87ce
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(logging.getLogger().level, getattr(logging, 'INFO')))
+    logging.getLogger('amqp').setLevel(logging.WARNING)
     logger.info('Starting pipeline listener')
 
     fits_exchange = Exchange(runtime_context.FITS_EXCHANGE, type='fanout')