-
Notifications
You must be signed in to change notification settings - Fork 480
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[RayService] Avoid sending health check requests to the head Pod when excludeHeadPodFromServeSvc
is true
#2776
[RayService] Avoid sending health check requests to the head Pod when excludeHeadPodFromServeSvc
is true
#2776
Conversation
Signed-off-by: kaihsun <[email protected]>
@@ -121,7 +120,6 @@ func (r *RayServiceReconciler) Reconcile(ctx context.Context, request ctrl.Reque | |||
originalRayServiceInstance := rayServiceInstance.DeepCopy() | |||
|
|||
if err := validateRayServiceSpec(rayServiceInstance); err != nil { | |||
logger.Error(err, "The RayService spec is invalid") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@@ -1135,8 +1133,6 @@ func (r *RayServiceReconciler) reconcileServe(ctx context.Context, rayServiceIns | |||
} | |||
} | |||
|
|||
// TODO(architkulkarni): Check the RayVersion. If < 2.8.0, error. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
No one has complained about it for years. Remove the TODO.
@@ -1183,29 +1183,29 @@ func (r *RayServiceReconciler) labelHeadPodForServeStatus(ctx context.Context, r | |||
return fmt.Errorf("found 0 head. cluster name %s, namespace %v", rayClusterInstance.Name, rayClusterInstance.Namespace) | |||
} | |||
|
|||
httpProxyClient := r.httpProxyClientFunc() |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
httpProxy
is not very precise.
for key, value := range headPod.Labels { | ||
originalLabels[key] = value | ||
} | ||
if err = httpProxyClient.CheckProxyActorHealth(ctx); err == nil && !excludeHeadPodFromServeSvc { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
If excludeHeadPodFromServeSvc
is true, we don't need to send health check requests to the head Pod.
cc @rueian |
… `excludeHeadPodFromServeSvc` is true (ray-project#2776) Signed-off-by: kaihsun <[email protected]>
… `excludeHeadPodFromServeSvc` is true (ray-project#2776) Signed-off-by: kaihsun <[email protected]>
Why are these changes needed?
Related issue number
Checks