From e997da05e2f13d134c731335b7fc78bd5f66b178 Mon Sep 17 00:00:00 2001 From: Mark Date: Sun, 30 Aug 2026 09:52:31 -0700 Subject: [PATCH] =?UTF-8?q?fix:=20remove=20no-op=C2=A0WorkersToDelete?= =?UTF-8?q?=C2=A0resets=20in=20RayCluster=20controller?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Mark --- ray-operator/controllers/ray/raycluster_controller.go | 4 ---- 1 file changed, 4 deletions(-) diff --git a/ray-operator/controllers/ray/raycluster_controller.go b/ray-operator/controllers/ray/raycluster_controller.go index 869a78a82be..331afb40dc7 100644 --- a/ray-operator/controllers/ray/raycluster_controller.go +++ b/ray-operator/controllers/ray/raycluster_controller.go @@ -1150,7 +1150,6 @@ func (r *RayClusterReconciler) reconcilePods(ctx context.Context, instance *rayv r.Recorder.Eventf(instance, nil, corev1.EventTypeNormal, string(utils.DeletedWorkerPod), string(utils.DeleteAction), "Deleted pod %s/%s", pod.Namespace, pod.Name) } } - worker.ScaleStrategy.WorkersToDelete = []string{} runningPods := corev1.PodList{} for _, pod := range workerPods.Items { @@ -1355,11 +1354,8 @@ func (r *RayClusterReconciler) reconcileMultiHostWorkerGroup(ctx context.Context if err := r.deletePods(ctx, instance, podsToDel, worker.GroupName, "autoscaler scale-down request"); err != nil { return err } - worker.ScaleStrategy.WorkersToDelete = []string{} return fmt.Errorf("deleted %d worker Pods based on ScaleStrategy, requeueing", len(podsToDel)) } - // Clear WorkersToDelete after deletion. - worker.ScaleStrategy.WorkersToDelete = []string{} } // 5. Calculate Pod diff for scaling up or down by NumOfHosts.