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.

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

[core][compiled-graphs] Support wait-and-get to round-robin the acquisition of mutable objects allowing for fast failure #49444

Closed
wants to merge 30 commits into from
Closed
Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
30 commits
Select commit Hold shift + click to select a range
e631160
pass tests
kevin85421 Dec 26, 2024
bf585fa
pass tests, refactor
kevin85421 Dec 26, 2024
bf7a26e
pass tests, waitables
kevin85421 Dec 26, 2024
93bff72
update
kevin85421 Dec 26, 2024
d68f8db
pass tests
kevin85421 Dec 27, 2024
aa7b831
pass tests, retrieve obj one by one in sync reader
kevin85421 Dec 27, 2024
a22bbaa
update
kevin85421 Dec 30, 2024
d1aac6c
update comment and move import to top-level
kevin85421 Dec 30, 2024
a84e561
remove logs and update comments for WaitAndGetExperimentalMutableObjects
kevin85421 Dec 30, 2024
9e44591
update comments
kevin85421 Dec 30, 2024
3ddad3a
add some utils
kevin85421 Dec 30, 2024
4ca28e9
fix test_channel tests
kevin85421 Dec 30, 2024
d8dadb4
update
kevin85421 Dec 31, 2024
5d18be7
Merge remote-tracking branch 'upstream/master' into 20241224-2
kevin85421 Dec 31, 2024
cddaef7
fix test_channel
kevin85421 Dec 31, 2024
abd4d28
update type hint
kevin85421 Dec 31, 2024
a684329
remove c++ log
kevin85421 Dec 31, 2024
2a1b3fc
update _read_list
kevin85421 Dec 31, 2024
9a3ae27
refactor
kevin85421 Dec 31, 2024
9f2f1d1
remove comment for visualize tests
kevin85421 Dec 31, 2024
ba489c3
add tests
kevin85421 Dec 31, 2024
ebbee6f
address comments
kevin85421 Dec 31, 2024
8ebe78c
move retrieve_obj_refs to util
kevin85421 Dec 31, 2024
d958b24
fix lint error
kevin85421 Dec 31, 2024
551bacb
fix nccl channel tests
kevin85421 Jan 1, 2025
1ae976b
fix test
kevin85421 Jan 1, 2025
1cc8210
fix typo
kevin85421 Jan 1, 2025
8c4e61d
refactor
kevin85421 Jan 1, 2025
6d22187
Merge remote-tracking branch 'upstream/master' into 20241224-2
kevin85421 Jan 6, 2025
38c8652
fix lint
kevin85421 Jan 6, 2025
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 lint error
Signed-off-by: Kai-Hsun Chen <kaihsun@anyscale.com>
  • Loading branch information
kevin85421 committed Dec 31, 2024
commit d958b24e08e81fcc9787e9f49a0f75b595f78daa
2 changes: 1 addition & 1 deletion python/ray/_private/test_utils.py
Original file line number Diff line number Diff line change
Expand Up @@ -2335,4 +2335,4 @@ def retrieve_mutable_object_refs(channels, timeout_s=3):
all_waitables[i],
value,
waitable_to_num_consumers[all_waitables[i]],
)
)
2 changes: 1 addition & 1 deletion python/ray/tests/test_channel.py
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,6 @@
import ray.cluster_utils
import ray.exceptions
import ray.experimental.channel as ray_channel
from ray.experimental.channel.common import ChannelContext
from ray.experimental.channel.torch_tensor_type import TorchTensorType
from ray.exceptions import RayChannelError, RayChannelTimeoutError
from ray.util.scheduling_strategies import NodeAffinitySchedulingStrategy
Expand All @@ -31,6 +30,7 @@ def create_driver_actor():
)
).remote()


@pytest.mark.skipif(
sys.platform != "linux" and sys.platform != "darwin",
reason="Requires Linux or Mac.",
Expand Down