Mark jobs deleted through job context as inactive. (#592)

armadaproject · Jun 8, 2021 · a06961f · a06961f
1 parent 42bdcf0
commit a06961f
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/internal/executor/job_context/job_context.go b/internal/executor/job_context/job_context.go
@@ -46,7 +46,11 @@ func (c *ClusterJobContext) GetRunningJobs() ([]*RunningJob, error) {
 }
 
 func (c *ClusterJobContext) DeleteJobs(jobs []*RunningJob) {
+ c.activeJobIdsMutex.Lock()
+ defer c.activeJobIdsMutex.Unlock()
+
  for _, job := range jobs {
+ delete(c.activeJobIds, job.JobId)
  c.clusterContext.DeletePods(job.Pods)
  }
 }