Commit c95604f

authored

Ensure that batch containers' kubexit death dependencies environment variable is deterministic (#2410)

1 parent 2e113bd commit c95604fCopy full SHA for c95604f

File tree

-2

lines changed

-2

lines changed

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -266,7 +266,7 @@ func TaskContainers(api spec.API, job *spec.JobKey) ([]kcore.Container, []kcore.`
`266`	`266`
`267`	`267`	`containerDeathDependencies := containerNames.Copy()`
`268`	`268`	`containerDeathDependencies.Remove(c.Name)`
`269`		`- containerDeathEnvVars := getKubexitEnvVars(c.Name, containerDeathDependencies.Slice(), nil)`
	`269`	`+ containerDeathEnvVars := getKubexitEnvVars(c.Name, containerDeathDependencies.SliceSorted(), nil)`
`270`	`270`	`containers[i].Env = append(containers[i].Env, containerDeathEnvVars...)`
`271`	`271`
`272`	`272`	`if c.Command[0] != "/cortex/kubexit" {`
`@@ -303,7 +303,7 @@ func BatchContainers(api spec.API, job *spec.BatchJob) ([]kcore.Container, []kco`
`303`	`303`
`304`	`304`	`containerDeathDependencies := containerNames.Copy()`
`305`	`305`	`containerDeathDependencies.Remove(c.Name)`
`306`		`- containerDeathEnvVars := getKubexitEnvVars(c.Name, containerDeathDependencies.Slice(), nil)`
	`306`	`+ containerDeathEnvVars := getKubexitEnvVars(c.Name, containerDeathDependencies.SliceSorted(), nil)`
`307`	`307`	`containers[i].Env = append(containers[i].Env, containerDeathEnvVars...)`
`308`	`308`
`309`	`309`	`if c.Command[0] != "/cortex/kubexit" {`

Comments

(0)