fix for missing periodic task name in rabbitmq

celery · Oct 8, 2024 · 8ea61e1 · 8ea61e1
1 parent 2e717da
commit 8ea61e1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/django_celery_results/backends/database.py b/django_celery_results/backends/database.py
@@ -87,8 +87,8 @@ def _get_extended_properties(self, request, traceback):
             if task_kwargs is not None:
                 _, _, task_kwargs = self.encode_content(task_kwargs)
 
-            properties = getattr(request, 'properties', {}) or {}
-            periodic_task_name = properties.get('periodic_task_name', None)
+            periodic_task_name = getattr(request, 'periodic_task_name', None)
+
             extended_props.update({
                 'periodic_task_name': periodic_task_name,
                 'task_args': task_args,