Function TaskContainers

pkg/workloads/k8s.go:252–279

(api spec.API, job *spec.JobKey)

}

func TaskContainers(api spec.API, job *spec.JobKey) ([]kcore.Container, []kcore.Volume) {
	containers, volumes := userPodContainers(api)
	k8sName := job.K8sName()

	volumes = append(volumes,
		KubexitVolume(),
		APIConfigVolume(k8sName),
	)

	containerNames := userconfig.GetContainerNames(api.Pod.Containers)
	for i, c := range containers {
		containers[i].VolumeMounts = append(containers[i].VolumeMounts,
			KubexitMount(),
			APIConfigMount(k8sName),
		)

		containerDeathDependencies := containerNames.Copy()
		containerDeathDependencies.Remove(c.Name)
		containerDeathEnvVars := getKubexitEnvVars(c.Name, containerDeathDependencies.SliceSorted(), nil)
		containers[i].Env = append(containers[i].Env, containerDeathEnvVars...)

		if c.Command[0] != "/cortex/kubexit" {
			containers[i].Command = append([]string{"/cortex/kubexit"}, c.Command...)
		}
	}

	return containers, volumes
}

func BatchContainers(api spec.API, job *spec.BatchJob) ([]kcore.Container, []kcore.Volume) {
	userContainers, userVolumes := userPodContainers(api)