From 29d222be83b99a951b24b87bd366c610a2b22f19 Mon Sep 17 00:00:00 2001 From: Jessica Mack Date: Wed, 1 Feb 2023 15:47:27 -0500 Subject: [PATCH] removed rsyslog queue, updated logger level Signed-off-by: Jessica Mack --- awx/main/management/commands/run_cache_clear.py | 2 +- awx/main/management/commands/run_dispatcher.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/awx/main/management/commands/run_cache_clear.py b/awx/main/management/commands/run_cache_clear.py index d058b8bd6e..dcb5c08aa9 100644 --- a/awx/main/management/commands/run_cache_clear.py +++ b/awx/main/management/commands/run_cache_clear.py @@ -23,7 +23,7 @@ class Command(BaseCommand): for e in conn.events(yield_timeouts=True): if e is not None: body = json.loads(e.payload) - logger.warning(f"Cache clear request received. Clearing now, payload: {e.payload}") + logger.info(f"Cache clear request received. Clearing now, payload: {e.payload}") TaskWorker.run_callable(body) else: logger.info('run_clear_cache got timeout') diff --git a/awx/main/management/commands/run_dispatcher.py b/awx/main/management/commands/run_dispatcher.py index 72fbfbedba..f7079c6a3c 100644 --- a/awx/main/management/commands/run_dispatcher.py +++ b/awx/main/management/commands/run_dispatcher.py @@ -76,7 +76,7 @@ class Command(BaseCommand): consumer = None try: - queues = ['tower_broadcast_all', 'tower_settings_change', 'rsyslog_configurer', get_local_queuename()] + queues = ['tower_broadcast_all', 'tower_settings_change', get_local_queuename()] consumer = AWXConsumerPG('dispatcher', TaskWorker(), queues, AutoscalePool(min_workers=4)) consumer.run() except KeyboardInterrupt: