refactor: move using attr from _get_result_meta to _store_result

celery · Jun 3, 2022 · bde3eef · bde3eef
1 parent 36aeaeb
commit bde3eef
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/django_celery_results/backends/database.py b/django_celery_results/backends/database.py
@@ -54,14 +54,13 @@ def exception_safe_to_retry(self, exc):
                 return True
         return False
 
-    def _get_result_meta(self, request, traceback, using):
+    def _get_result_meta(self, request, traceback):
         extended_props = {
             'periodic_task_name': None,
             'task_args': None,
             'task_kwargs': None,
             'task_name': None,
             'traceback': None,
-            'using': None,
             'worker': None,
         }
         if request and self.app.conf.find_value_for_key('extended', 'result'):
@@ -95,7 +94,6 @@ def _get_result_meta(self, request, traceback, using):
                 'task_kwargs': task_kwargs,
                 'task_name': getattr(request, 'task', None),
                 'traceback': traceback,
-                'using': using,
                 'worker': getattr(request, 'hostname', None),
             })
 
@@ -124,6 +122,7 @@ def _store_result(
             'status': status,
             'task_id': task_id,
             'traceback': traceback,
+            'using': using,
         }
 
         task_props.update(