Panic if job gets into a state it is not queued but has no runs

armadaproject · May 4, 2023 · dbff26a · dbff26a
1 parent 65bd57e
commit dbff26a
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/internal/scheduler/scheduler.go b/internal/scheduler/scheduler.go
@@ -294,6 +294,13 @@ func (s *Scheduler) syncState(ctx context.Context) ([]*jobdb.Job, error) {
 	}
 
 	jobsToUpdate := maps.Values(jobsToUpdateById)
+
+	for _, job := range jobsToUpdate {
+		if !job.Queued() && !job.HasRuns() {
+			panic(fmt.Sprintf("job %s is not queued but has no runs", job.Id()))
+		}
+	}
+
 	err = s.jobDb.BatchDelete(txn, jobsToDelete)
 	if err != nil {
 		return nil, err