quick fix for multi-host indexing (#4139)

chiayi · web-flow · commit 010cb06d50bb · 2025-10-23T14:02:19.000-07:00
diff --git a/ray-operator/controllers/ray/raycluster_controller.go b/ray-operator/controllers/ray/raycluster_controller.go
@@ -915,7 +915,7 @@ func (r *RayClusterReconciler) reconcileMultiHostWorkerGroup(ctx context.Context
 		for i := 0; i < replicasToCreate; i++ {
 			replicaName := utils.GenerateRayWorkerReplicaGroupName(worker.GroupName)
 			for j := 0; j < int(worker.NumOfHosts); j++ {
-				if err := r.createWorkerPodWithIndex(ctx, *instance, *worker, replicaName, j); err != nil {
+				if err := r.createWorkerPodWithIndex(ctx, *instance, *worker.DeepCopy(), replicaName, j); err != nil {
 					return errstd.Join(utils.ErrFailedCreateWorkerPod, err)
 				}
 			}

Original file line number	Diff line number	Diff line change
`@@ -915,7 +915,7 @@ func (r *RayClusterReconciler) reconcileMultiHostWorkerGroup(ctx context.Context`
`915`	`915`	`for i := 0; i < replicasToCreate; i++ {`
`916`	`916`	`replicaName := utils.GenerateRayWorkerReplicaGroupName(worker.GroupName)`
`917`	`917`	`for j := 0; j < int(worker.NumOfHosts); j++ {`
`918`		`- if err := r.createWorkerPodWithIndex(ctx, instance, worker, replicaName, j); err != nil {`
	`918`	`+ if err := r.createWorkerPodWithIndex(ctx, instance, worker.DeepCopy(), replicaName, j); err != nil {`
`919`	`919`	`return errstd.Join(utils.ErrFailedCreateWorkerPod, err)`
`920`	`920`	`}`
`921`	`921`	`}`