@@ -309,95 +309,95 @@ func (n *NIMService) GetLWSLeaderEnv() []corev1.EnvVar {
309309 mpiTimeout = n .Spec .MultiNode .MPI .MPIStartTimeout
310310 }
311311
312- env = append ( env ,
313- corev1. EnvVar {
312+ env = utils . MergeEnvVars ([]corev1. EnvVar {
313+ {
314314 Name : "NIM_LEADER_ROLE" ,
315315 Value : "1" ,
316316 },
317- corev1. EnvVar {
317+ {
318318 Name : "NIM_MPI_ALLOW_RUN_AS_ROOT" ,
319319 Value : "0" ,
320320 },
321- corev1. EnvVar {
321+ {
322322 Name : "OMPI_MCA_orte_keep_fqdn_hostnames" ,
323323 Value : "true" ,
324324 },
325- corev1. EnvVar {
325+ {
326326 Name : "OMPI_MCA_plm_rsh_args" ,
327327 Value : "-o ConnectionAttempts=20" ,
328328 },
329- corev1. EnvVar {
329+ {
330330 Name : "NIM_NUM_COMPUTE_NODES" ,
331331 Value : fmt .Sprintf ("%d" , n .Spec .MultiNode .Size ),
332332 },
333- corev1. EnvVar {
333+ {
334334 Name : "GPUS_PER_NODE" ,
335335 Value : fmt .Sprintf ("%d" , n .Spec .MultiNode .GPUSPerPod ),
336336 },
337- corev1. EnvVar {
337+ {
338338 Name : "CLUSTER_START_TIMEOUT" ,
339339 Value : fmt .Sprintf ("%d" , mpiTimeout ),
340340 },
341- corev1. EnvVar {
341+ {
342342 Name : "CLUSTER_SIZE" ,
343343 ValueFrom : & corev1.EnvVarSource {
344344 FieldRef : & corev1.ObjectFieldSelector {
345345 FieldPath : "metadata.annotations['leaderworkerset.sigs.k8s.io/size']" ,
346346 },
347347 },
348348 },
349- corev1. EnvVar {
349+ {
350350 Name : "GROUP_INDEX" ,
351351 ValueFrom : & corev1.EnvVarSource {
352352 FieldRef : & corev1.ObjectFieldSelector {
353353 FieldPath : "metadata.labels['leaderworkerset.sigs.k8s.io/group-index']" ,
354354 },
355355 },
356356 },
357- )
357+ }, env )
358358 return env
359359}
360360
361361func (n * NIMService ) GetLWSWorkerEnv () []corev1.EnvVar {
362362 env := n .GetEnv ()
363- env = append ( env ,
364- corev1. EnvVar {
363+ env = utils . MergeEnvVars ([]corev1. EnvVar {
364+ {
365365 Name : "NIM_LEADER_ROLE" ,
366366 Value : "0" ,
367367 },
368- corev1. EnvVar {
368+ {
369369 Name : "NIM_MPI_ALLOW_RUN_AS_ROOT" ,
370370 Value : "0" ,
371371 },
372- corev1. EnvVar {
372+ {
373373 Name : "NIM_NUM_COMPUTE_NODES" ,
374374 Value : fmt .Sprintf ("%d" , n .Spec .MultiNode .Size ),
375375 },
376- corev1. EnvVar {
376+ {
377377 Name : "LEADER_NAME" ,
378378 ValueFrom : & corev1.EnvVarSource {
379379 FieldRef : & corev1.ObjectFieldSelector {
380380 FieldPath : "metadata.annotations['leaderworkerset.sigs.k8s.io/leader-name']" ,
381381 },
382382 },
383383 },
384- corev1. EnvVar {
384+ {
385385 Name : "NAMESPACE" ,
386386 ValueFrom : & corev1.EnvVarSource {
387387 FieldRef : & corev1.ObjectFieldSelector {
388388 FieldPath : "metadata.namespace" ,
389389 },
390390 },
391391 },
392- corev1. EnvVar {
392+ {
393393 Name : "LWS_NAME" ,
394394 ValueFrom : & corev1.EnvVarSource {
395395 FieldRef : & corev1.ObjectFieldSelector {
396396 FieldPath : "metadata.labels['leaderworkerset.sigs.k8s.io/name']" ,
397397 },
398398 },
399399 },
400- )
400+ }, env )
401401 return env
402402}
403403
0 commit comments