Explorar o código

Prepare exception to pickle when saving RETRY status.

Jerzy Kozera %!s(int64=16) %!d(string=hai) anos
pai
achega
291507f0f6
Modificáronse 1 ficheiros con 1 adicións e 1 borrados
  1. 1 1
      celery/backends/database.py

+ 1 - 1
celery/backends/database.py

@@ -34,7 +34,7 @@ class Backend(BaseBackend):
         """Store return value and status of an executed task."""
         if status == "DONE":
             result = self.prepare_result(result)
-        elif status == "FAILURE":
+        elif status in ["FAILURE", "RETRY"]:
             result = self.prepare_exception(result)
         TaskMeta.objects.store_result(task_id, result, status,
                                       traceback=traceback)