Skip to content
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.

Sign up for GitHub

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

Jump to bottom

[core]Turn on light weight resource broadcasting. #32625

Merged
merged 13 commits into from
Mar 1, 2023
Merged

[core]Turn on light weight resource broadcasting. #32625

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
b999fda
reset
fishbone Feb 22, 2023
a7098c4
Merge remote-tracking branch 'upstream/master' into turn-on-lwr
fishbone Feb 22, 2023
98ea7ab
fix the crash
fishbone Feb 22, 2023
d398ff4
fix
fishbone Feb 22, 2023
2c7669f
fix
fishbone Feb 22, 2023
9ac7f05
fix crash
fishbone Feb 23, 2023
5420471
fix test
fishbone Feb 23, 2023
d9f9605
fix
fishbone Feb 23, 2023
0ce41dd
fix
fishbone Feb 23, 2023
2cc3fa5
fix
fishbone Feb 23, 2023
5ba7533
Merge remote-tracking branch 'upstream/master' into turn-on-lwr
fishbone Feb 24, 2023
23794ae
Merge remote-tracking branch 'upstream/master' into turn-on-lwr
fishbone Feb 28, 2023
7c7f165
Merge remote-tracking branch 'upstream/master' into turn-on-lwr
fishbone Mar 1, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
fix
  • Loading branch information
@fishbone
fishbone committed Feb 23, 2023
commit d9f9605c18136848f60672d76f11707c99f284a1
3 changes: 2 additions & 1 deletion release/release_tests.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3881,6 +3881,7 @@
run:
timeout: 3600
script: python distributed/test_many_actors.py
type: sdk_command
wait_for_nodes:
num_nodes: 65

Expand Down Expand Up @@ -4624,7 +4625,7 @@
script: RAY_DATASET_PUSH_BASED_SHUFFLE=1 python dataset/sort.py --num-partitions=1000 --partition-size=1e9 --shuffle
wait_for_nodes:
num_nodes: 20

type: sdk_command

#####################
Expand Down
6 changes: 5 additions & 1 deletion src/ray/common/ray_syncer/ray_syncer.cc
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -108,7 +108,11 @@ void RayServerBidiReactor::DoDisconnect() {
io_context_.dispatch([this]() { Finish(grpc::Status::OK); }, "");
}

void RayServerBidiReactor::OnCancel() { Disconnect(); }
void RayServerBidiReactor::OnCancel() {
io_context_.dispatch([this]() {
Disconnect();
}, "");
}

void RayServerBidiReactor::OnDone() {
io_context_.dispatch(
Expand Down