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()):