From c90e399165489559e06420d03ac76c11445ec97f Mon Sep 17 00:00:00 2001 From: Curtis McCully Date: Thu, 10 Aug 2023 22:55:40 -0400 Subject: [PATCH] Raised the level of logging for celery. --- banzai/main.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/banzai/main.py b/banzai/main.py index 4f2dfa5a..2065ed3c 100755 --- 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')