Fix properties default value (#281)

* Fix properties default value * Add default value to getattr to avoid exception
celery · Jan 26, 2022 · cf17067 · cf17067
1 parent 5f47db6
commit cf17067
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/django_celery_results/backends/database.py b/django_celery_results/backends/database.py
@@ -40,7 +40,7 @@ def _store_result(
         )
 
         task_name = getattr(request, 'task', None)
-        properties = getattr(request, 'properties', {})
+        properties = getattr(request, 'properties', {}) or {}
         periodic_task_name = properties.get('periodic_task_name', None)
         worker = getattr(request, 'hostname', None)
 

diff --git a/t/unit/backends/test_database.py b/t/unit/backends/test_database.py
@@ -45,7 +45,7 @@ def _create_request(self, task_id, name, args, kwargs,
         )
         if task_protocol == 1:
             body, headers, _, _ = hybrid_to_proto2(msg, msg.body)
-            properties = {}
+            properties = None
             sent_event = {}
         else:
             headers, properties, body, sent_event = msg