fixed faulty done status assignment

spotify · Jan 5, 2024 · 1cae8c2 · 1cae8c2
1 parent b5be147
commit 1cae8c2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/luigi/worker.py b/luigi/worker.py
@@ -213,7 +213,7 @@ def run(self):
                         # update the cache
                         if self.task_completion_cache is not None:
                             self.task_completion_cache[self.task.task_id] = True
-                        status = DONE
+                        status = DONE if self.task.complete() else FAILED
                     elif self.check_complete(self.task):
                         status = DONE
                     else: