From 7eaa056a4ed9f6883c47845bd95528f8bec29b42 Mon Sep 17 00:00:00 2001
From: ThanKarab <tkarabatsis@hotmail.com>
Date: Thu, 28 Nov 2024 15:39:29 +0200
Subject: [PATCH] Fix for worker celery logger
---
exareme2/worker/utils/celery_app.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/exareme2/worker/utils/celery_app.py b/exareme2/worker/utils/celery_app.py
index 00b5677f..fe48817c 100644
--- a/exareme2/worker/utils/celery_app.py
+++ b/exareme2/worker/utils/celery_app.py
@@ -40,7 +40,7 @@ worker_logger.info("Celery app created.")
def setup_celery_logging(*args, **kwargs):
logger = logging.getLogger()
formatter = logging.Formatter(
- f"%(asctime)s - %(levelname)s - CELERY FRAMEWORK - [{worker_config.federation}] - [exareme2-controller] - [{worker_config.identifier}] - [FRAMEWORK] - %(message)s"
+ f"%(asctime)s - %(levelname)s - CELERY FRAMEWORK - [{worker_config.federation}] - [exareme2-{worker_config.role.lower()}] - [{worker_config.identifier}] - [FRAMEWORK] - %(message)s"
)
# StreamHandler
--
GitLab