diff --git a/src/master/taskmgr.py b/src/master/taskmgr.py index 1e501a0..99b1fc8 100644 --- a/src/master/taskmgr.py +++ b/src/master/taskmgr.py @@ -515,6 +515,7 @@ class TaskMgr(threading.Thread): task.status = FAILED task.failed_reason = report.errmsg elif report.subTaskStatus == COMPLETED: + sub_task.status = report.subTaskStatus self.clear_sub_task(sub_task) # return task, workers