fix for missing periodic task name in results

celery · Oct 8, 2024 · 3ab299e · 3ab299e
1 parent 78d3230
commit 3ab299e
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/django_celery_beat/admin.py b/django_celery_beat/admin.py
@@ -248,12 +248,13 @@ def run_tasks(self, request, queryset):
             )
             return
 
+        headers = {'periodic_task_name':periodic_task_name}
+
         task_ids = [
             task.apply_async(args=args, kwargs=kwargs, queue=queue,
-                             periodic_task_name=periodic_task_name)
+                             headers=headers)
             if queue and len(queue)
-            else task.apply_async(args=args, kwargs=kwargs,
-                                  periodic_task_name=periodic_task_name)
+            else task.apply_async(args=args, kwargs=kwargs, headers=headers)
             for task, args, kwargs, queue, periodic_task_name in tasks
         ]
         tasks_run = len(task_ids)