-
Notifications
You must be signed in to change notification settings - Fork 328
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
[Ray] Fix ray executor progress test #3033
[Ray] Fix ray executor progress test #3033
Conversation
|
||
t1 = t.sum() | ||
r = t1.map_chunk(f1) | ||
info = await session.execute(r) |
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.
How long does this test case take? I noticed that there is a time.sleep(2)
in the f1
.
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.
It takes about 5s on mars executor, 10s on ray executor.
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.
Can you make it faster? Ray backend is slower because:
- import ray
- start ray cluster
- ray kill idle worker (we can config
kill_idle_workers_interval_ms
to 0, please refer to https://github.com/ray-project/ray/blob/master/src/ray/common/ray_config_def.h#L399)
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.
Thanks for you reminder. I've fixed it. Now its cost is about 6s on ray.
@fyrestone Could you please review this PR to see if there is any further issue? |
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.
LGTM
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.
LGTM
What do these changes do?
Ray executor progress test does not run due to lack of await. This pr fixed it.
Related issue number
Fixes #xxxx
Check code requirements