From e3129c10674f5f997051badc456f2c20f3d28cb9 Mon Sep 17 00:00:00 2001 From: Jens Langhammer Date: Sat, 11 Dec 2021 13:59:56 +0100 Subject: [PATCH] root: bump celery messages to info Signed-off-by: Jens Langhammer --- authentik/root/celery.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/authentik/root/celery.py b/authentik/root/celery.py index 17e9a863f..ad6c8bcbd 100644 --- a/authentik/root/celery.py +++ b/authentik/root/celery.py @@ -37,7 +37,7 @@ def config_loggers(*args, **kwargs): def after_task_publish_hook(sender=None, headers=None, body=None, **kwargs): """Log task_id after it was published""" info = headers if "task" in headers else body - LOGGER.debug("Task published", task_id=info.get("id", ""), task_name=info.get("task", "")) + LOGGER.info("Task published", task_id=info.get("id", ""), task_name=info.get("task", "")) # pylint: disable=unused-argument @@ -48,14 +48,14 @@ def task_prerun_hook(task_id: str, task, *args, **kwargs): LOCAL.authentik_task = { "request_id": request_id, } - LOGGER.debug("Task started", task_id=task_id, task_name=task.__name__) + LOGGER.info("Task started", task_id=task_id, task_name=task.__name__) # pylint: disable=unused-argument @task_postrun.connect def task_postrun_hook(task_id, task, *args, retval=None, state=None, **kwargs): """Log task_id on worker""" - LOGGER.debug("Task finished", task_id=task_id, task_name=task.__name__, state=state) + LOGGER.info("Task finished", task_id=task_id, task_name=task.__name__, state=state) if not hasattr(LOCAL, "authentik_task"): return for key in list(LOCAL.authentik_task.keys()):