Reset Redis job status based on job file content on startup

soedinglab · Apr 16, 2024 · 19123bf · 19123bf
1 parent 31333dd
commit 19123bf
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/backend/jobsystem.go b/backend/jobsystem.go
@@ -204,10 +204,13 @@ func MakeRedisJobSystem(config ConfigRedis, results string) (*RedisJobSystem, er
 			}
 		}
 		job, err := getJobRequestFromFile(file)
-		if err != nil || job.Status != StatusComplete {
+		if err != nil {
+			continue
+		}
+		if job.Status != StatusComplete {
 			job.Status = StatusError
-			jobsystem.SetStatus(job.Id, StatusError)
 		}
+		jobsystem.SetStatus(job.Id, job.Status)
 	}
 
 	return jobsystem, nil