-
Notifications
You must be signed in to change notification settings - Fork 6k
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
Fix release test -- client remote put #15325
Conversation
if self.num_clients == 0: | ||
with disable_client_hook(): |
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.
Why do we change swap this?
} | ||
|
||
def ray_connect_handler(job_config=None): | ||
import ray as real_ray |
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.
should import ray
just work? I feel disable_client_hook will take care of everything.
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.
Well, if you don't have the import in here and only the disable_client_hook, the behavior is actually unexpected (and fails).
So it's important to have some form of import in here, but I felt that real_ray
was more readable and would prevent scoping problems
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.
Ah, you misunderstood me.
I mean we don't necessarily rename it to real_ray
since it doesn't quite make sense here.
If you don't call with disable_client_hook, it's actually not real_ray, right?
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.
OK i tried a small fix here!
@richardliaw could you give more details about this PR? Or could you give any link to the issues related to this PR? I don't quite understand what's the issue fixed here. |
Thanks @iycheng for the fast review! I've added some contextual information in the PR description. Please take a look again? |
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.
Overall, I feel good about this PR. I'll give an approval. The comment is NIT. It's up to you to change this.
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.
Looks good to me - as ray_start_client_server
seems to be a testing utility I'm fine with changing this just for this benchmarking test.
I'm wondering though if we should move the new ray connect handler to ray_start_cluster_client_server_pair()
, but I'm lacking client code context to really judge that.
Happy to go forward with this solution for now as it won't affect other tests.
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.
This looks good to me. It may make sense to move other tests to use this fixture in the future, but just scoping it to perf tests for now is okay with me.
4 Approvals oughta be enough.
merging |
* fix-test Signed-off-by: Richard Liaw <rliaw@berkeley.edu> * fix Signed-off-by: Richard Liaw <rliaw@berkeley.edu> * Update python/ray/util/client/server/dataservicer.py * Update python/ray/util/client/server/dataservicer.py * Update python/ray/_private/ray_client_microbenchmark.py
Why are these changes needed?
Enables a system config for the ray client tests:
New output for
remote put
:Prior to this PR:
Full run:
Related issue number
Addresses part of #15247
Checks
scripts/format.sh
to lint the changes in this PR.