Add resource requests for TaskAPI when CPU is used

RobertLucian · RobertLucian · commit b82abd3a14ad · 2021-01-19T18:04:30.000+02:00
diff --git a/pkg/operator/operator/k8s.go b/pkg/operator/operator/k8s.go
@@ -166,6 +166,13 @@ func TaskContainers(api *spec.API) ([]kcore.Container, []kcore.Volume) {
 		}
 
 		containers = append(containers, neuronContainer)
+	} else {
+		if api.Compute.CPU != nil {
+			apiPodResourceList[kcore.ResourceCPU] = api.Compute.CPU.DeepCopy()
+		}
+		if api.Compute.Mem != nil {
+			apiPodResourceList[kcore.ResourceMemory] = api.Compute.Mem.DeepCopy()
+		}
 	}
 
 	containers = append(containers, kcore.Container{

Original file line number	Diff line number	Diff line change
`@@ -166,6 +166,13 @@ func TaskContainers(api *spec.API) ([]kcore.Container, []kcore.Volume) {`
`166`	`166`	`}`
`167`	`167`
`168`	`168`	`containers = append(containers, neuronContainer)`
	`169`	`+ } else {`
	`170`	`+ if api.Compute.CPU != nil {`
	`171`	`+ apiPodResourceList[kcore.ResourceCPU] = api.Compute.CPU.DeepCopy()`
	`172`	`+ }`
	`173`	`+ if api.Compute.Mem != nil {`
	`174`	`+ apiPodResourceList[kcore.ResourceMemory] = api.Compute.Mem.DeepCopy()`
	`175`	`+ }`
`169`	`176`	`}`
`170`	`177`
`171`	`178`	`containers = append(containers, kcore.Container{`