diff --git a/backend/model/task.go b/backend/model/task.go index 71948e26..6b8d9121 100644 --- a/backend/model/task.go +++ b/backend/model/task.go @@ -452,7 +452,12 @@ func UpdateTaskToAbnormal(nodeId bson.ObjectId) error { selector := bson.M{ "node_id": nodeId, - "status": constants.StatusRunning, + "status": bson.M{ + "$in": []string{ + constants.StatusPending, + constants.StatusRunning, + }, + }, } update := bson.M{ "$set": bson.M{