rename

ray-project · Apr 7, 2024 · 3d87528 · 3d87528
1 parent 45b7c35
commit 3d87528
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/ray-operator/controllers/ray/common/association.go b/ray-operator/controllers/ray/common/association.go
@@ -74,7 +74,7 @@ func RayClusterWorkerPodsAssociationOptions(instance *rayv1.RayCluster) Associat
 	}
 }
 
-func RayClusterRedisPodAssociationOptions(instance *rayv1.RayCluster) AssociationOptions {
+func RayClusterRedisCleanupPodAssociationOptions(instance *rayv1.RayCluster) AssociationOptions {
 	return AssociationOptions{
 		client.InNamespace(instance.Namespace),
 		client.MatchingLabels{

diff --git a/ray-operator/controllers/ray/raycluster_controller.go b/ray-operator/controllers/ray/raycluster_controller.go
@@ -249,7 +249,7 @@ func (r *RayClusterReconciler) rayClusterReconcile(ctx context.Context, request
 
 			// We can start the Redis cleanup process now because the head Pod has been terminated.
 			redisCleanupJobs := batchv1.JobList{}
-			if err := r.List(ctx, &redisCleanupJobs, common.RayClusterRedisPodAssociationOptions(instance).ToListOptions()...); err != nil {
+			if err := r.List(ctx, &redisCleanupJobs, common.RayClusterRedisCleanupPodAssociationOptions(instance).ToListOptions()...); err != nil {
 				return ctrl.Result{RequeueAfter: DefaultRequeueDuration}, err
 			}