- Notifications
You must be signed in to change notification settings - Fork6.6k
[WIP] Multinode DAG minus FT changes#42173
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 ourterms of service andprivacy statement. We’ll occasionally send you account related emails.
Already on GitHub?Sign in to your account
Closed
stephanie-wang wants to merge86 commits intoray-project:masterfromstephanie-wang:multinode-dag-minus-ft
Uh oh!
There was an error while loading.Please reload this page.
Closed
Changes from1 commit
Commits
Show all changes
86 commits Select commitHold shift + click to select a range
3044247
ip
8c5efd8
basic working.
664b07a
enhancement
8f6f8d2
working now.
12b977d
initial commit
stephanie-wang1c935b9
Add special calls for create and put mutable objects
stephanie-wangc2dbf1f
feature flag for shared mem seal, only acquire once per ray.get
stephanie-wang6d4aa94
put-get
stephanie-wangbc4f1e9
rm shared mem seal
stephanie-wangc4a2378
fix num_readers on first version, unit tests pass now
stephanie-wange40d3c8
mutable object -> channel
stephanie-wangb79b7d1
micro
stephanie-wang5ea0fe3
support different metadata
stephanie-wangcbe257f
better error message
stephanie-wanga68cefd
cleanup
stephanie-wangea57894
Test for errors, better error handling when too many readers
stephanie-wang5bbf379
remove unneeded
stephanie-wang1e16e09
java build
stephanie-wang14c3a44
Merge remote-tracking branch 'sang/dag-api' into compiled-dag
stephanie-wang580b3ad
rename
stephanie-wang888950a
Merge remote-tracking branch 'upstream/master' into compiled-dag
stephanie-wangbdfbb8a
tmp
stephanie-wangfe11cc3
test metadata change in remote reader
stephanie-wangb6a66f2
Merge branch 'mutable-objects-2' into compiled-dag
stephanie-wange11b614
build
stephanie-wangb6150a3
scatter-gather DAG works
stephanie-wang5336262
fix
stephanie-wang99a38c2
fix
stephanie-wange88c40f
fix
stephanie-wang95e871b
compile?
stephanie-wang204bb9b
fix
stephanie-wang4703f34
compile?
stephanie-wang420bd1c
build
stephanie-wang4cabbc5
x
stephanie-wangb44ef8a
fix
stephanie-wang13b1d53
Merge branch 'mutable-objects-2' into compiled-dag
stephanie-wange54972b
unit test
stephanie-wang881d5ff
copyright
stephanie-wangef2cfb7
test
stephanie-wangca22a63
Merge remote-tracking branch 'upstream/master' into mutable-objects-2
stephanie-wang5fbfac5
Merge branch 'mutable-objects-2' into compiled-dag
stephanie-wang9396810
tmp
stephanie-wangdbbb3d6
Only allocate PlasmaObjectHeader if is_mutable=true
stephanie-wang9078776
Only call Read/Write Acquire/Release if is_mutable=true
stephanie-wang2e677c3
x
stephanie-wangf06b543
cpp test
stephanie-wang950bbb4
Merge branch 'mutable-objects-2' into compiled-dag
stephanie-wang494cb53
Revert "tmp"
stephanie-wang05b002f
cleanup
stephanie-wang521c73b
Support no-OutputNode DAGs
stephanie-wang5b58250
Support non-DAG args
stephanie-wangb5beca4
errors
stephanie-wangcc2e795
lint
stephanie-wangc17c367
doc
stephanie-wang4dfa31e
skip tests on windows
stephanie-wang126296f
Merge remote-tracking branch 'upstream/master' into mutable-objects-2
stephanie-wang03f4fbd
larger CI machine
stephanie-wangb1f3f34
Merge branch 'mutable-objects-2' into compiled-dag
stephanie-wang3e7dfa2
Merge branch 'master' into mutable-objects-2
stephanie-wang7dde158
cleanup
stephanie-wang63cc16d
cleanup
stephanie-wangdca1239
perf
stephanie-wang7b8472b
add normal DAG
stephanie-wangd94c485
Merge remote-tracking branch 'upstream/master' into compiled-dag
stephanie-wang740169b
x
stephanie-wang3d5ffca
Merge branch 'mutable-objects-2' into compiled-dag
stephanie-wang8dde781
Merge remote-tracking branch 'upstream/master' into compiled-dag
stephanie-wang905a5bc
merge
stephanie-wang4436b1f
revert
stephanie-wangf105ed5
revert
stephanie-wang00f3f1c
x
stephanie-wang257457d
buffer size bytes
stephanie-wang71c32ae
optional
stephanie-wang2ba93f0
x
stephanie-wang3a4b2f4
Merge remote-tracking branch 'upstream/master' into compiled-dag
stephanie-wang973ba68
Merge remote-tracking branch 'upstream/master' into compiled-dag
stephanie-wangac5fa55
x
stephanie-wang35a37fd
lint?
stephanie-wang1326331
test
stephanie-wangfadec07
API
stephanie-wangff19557
x
stephanie-wang449c917
multinode channel
stephanie-wang94cd1f7
move channel manager to raylet
stephanie-wang8407999
it works
stephanie-wangb84c1bd
test multiple remote readers
stephanie-wang76bbdc2
Fix segfault in plasma client, multinode DAG works
stephanie-wangFile filter
Filter by extension
Conversations
Failed to load comments.
Loading
Uh oh!
There was an error while loading.Please reload this page.
Jump to
Jump to file
Failed to load files.
Loading
Uh oh!
There was an error while loading.Please reload this page.
Diff view
Diff view
Test for errors, better error handling when too many readers
Signed-off-by: Stephanie Wang <swang@cs.berkeley.edu>
- Loading branch information
Uh oh!
There was an error while loading.Please reload this page.
commitea57894f405c757d8faa6ed6077aecfc7c9db0cf
There are no files selected for viewing
10 changes: 6 additions & 4 deletionspython/ray/_private/ray_perf.py
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.Learn more about bidirectional Unicode characters
29 changes: 18 additions & 11 deletionspython/ray/experimental/channel.py
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.Learn more about bidirectional Unicode characters
49 changes: 49 additions & 0 deletionspython/ray/tests/test_accelerated_dag.py
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.Learn more about bidirectional Unicode characters
44 changes: 26 additions & 18 deletionssrc/ray/object_manager/common.cc
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.Learn more about bidirectional Unicode characters
39 changes: 25 additions & 14 deletionssrc/ray/object_manager/common.h
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.Learn more about bidirectional Unicode characters
Oops, something went wrong.
Uh oh!
There was an error while loading.Please reload this page.
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.