diff --git a/exareme2/worker/utils/celery_app.py b/exareme2/worker/utils/celery_app.py
index 00b5677fc278244c17d626ea8c86caca4978af56..fe48817c7575b187f09b20599578545acf7621cf 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