Merge pull request #138 from grycap/dev-srisco

Add RESOURCE_ID environment variable
grycap · Apr 11, 2022 · 59435f4 · 59435f4
2 parents bd81f4e + ac48be7
commit 59435f4
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/pkg/handlers/job.go b/pkg/handlers/job.go
@@ -89,6 +89,16 @@ func MakeJobHandler(cfg *types.Config, kubeClientset *kubernetes.Clientset, back
 			Value: jobUUID,
 		}
 
+		// Make RESOURCE_ID envVar
+		resourceIDVar := v1.EnvVar{
+			Name: "RESOURCE_ID",
+			ValueFrom: &v1.EnvVarSource{
+				FieldRef: &v1.ObjectFieldSelector{
+					FieldPath: "spec.nodeName",
+				},
+			},
+		}
+
 		// Get podSpec from the service
 		podSpec, err := service.ToPodSpec(cfg)
 		if err != nil {
@@ -103,6 +113,7 @@ func MakeJobHandler(cfg *types.Config, kubeClientset *kubernetes.Clientset, back
 				podSpec.Containers[i].Args = []string{"-c", fmt.Sprintf("echo $%s | %s", types.EventVariable, service.GetSupervisorPath())}
 				podSpec.Containers[i].Env = append(podSpec.Containers[i].Env, event)
 				podSpec.Containers[i].Env = append(podSpec.Containers[i].Env, jobUUIDVar)
+				podSpec.Containers[i].Env = append(podSpec.Containers[i].Env, resourceIDVar)
 			}
 		}