From 1cae8c21b823d6a2b86a8b9c9806cc1422ceaa6d Mon Sep 17 00:00:00 2001 From: Hadi Date: Fri, 5 Jan 2024 14:05:15 +0100 Subject: [PATCH] fixed faulty done status assignment --- luigi/worker.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/luigi/worker.py b/luigi/worker.py index c3ea777b8a..b32d448eb7 100644 --- 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: