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

[Streaming] fix streaming ci #9675

Merged
merged 42 commits into from
Sep 8, 2020
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
42 commits
Select commit Hold shift + click to select a range
c3f0ae5
fix replace proto import
chaokunyang Jul 24, 2020
c3bf18c
fix ArgByRef
chaokunyang Jul 27, 2020
d73a4d1
add explicit for TaskArgByValue
chaokunyang Jul 28, 2020
6d3e9c8
print binary for id check
chaokunyang Jul 28, 2020
e8715a5
fix arg by ref
chaokunyang Jul 28, 2020
accc059
refine wait file written
chaokunyang Jul 28, 2020
128988b
enforce protobuf version
chaokunyang Aug 12, 2020
c95c756
fix clear_object_ref
chaokunyang Aug 12, 2020
1670c7b
using wait_for_condition
chaokunyang Aug 12, 2020
d6de502
add comments for change import path
chaokunyang Aug 12, 2020
8b5f8f6
enforce protobuf version
chaokunyang Aug 12, 2020
9a5341e
revert protobuf version
chaokunyang Aug 12, 2020
0d39a8a
fix replace proto import
chaokunyang Jul 24, 2020
957c231
fix ArgByRef
chaokunyang Jul 27, 2020
0d5a561
add explicit for TaskArgByValue
chaokunyang Jul 28, 2020
c498cf7
print binary for id check
chaokunyang Jul 28, 2020
16daa11
fix arg by ref
chaokunyang Jul 28, 2020
eafc792
refine wait file written
chaokunyang Jul 28, 2020
eb0d371
enforce protobuf version
chaokunyang Aug 12, 2020
3baf8ac
fix clear_object_ref
chaokunyang Aug 12, 2020
12f6a13
using wait_for_condition
chaokunyang Aug 12, 2020
f6a0efd
add comments for change import path
chaokunyang Aug 12, 2020
d7102a1
enforce protobuf version
chaokunyang Aug 12, 2020
e842d16
revert protobuf version
chaokunyang Aug 12, 2020
115f726
Merge branch 'fix_streaming_ut' of https://github.com/ant-tech-allian…
Sep 4, 2020
2120b60
test.cc
Sep 4, 2020
17d4e4a
lint and refine name
chaokunyang Sep 4, 2020
12ef086
revert
chaokunyang Sep 4, 2020
75f4328
refine export symbols
chaokunyang Sep 4, 2020
75db61b
lint
chaokunyang Sep 4, 2020
359d17d
refine symbols export
chaokunyang Sep 5, 2020
2af9857
fix
chaokunyang Sep 5, 2020
e217239
lint
chaokunyang Sep 5, 2020
16c2a9f
lint
chaokunyang Sep 6, 2020
504a2ad
lint
chaokunyang Sep 7, 2020
28af33e
ld fixed
lixin-wei Sep 7, 2020
fba61d7
Merge branch 'master' of github.com:ray-project/ray into fix_streamin…
lixin-wei Sep 8, 2020
d8fe3cc
fix load_code_from_local
chaokunyang Sep 8, 2020
d2bba6f
stop ray cluster before test testHybridDataStream
chaokunyang Sep 8, 2020
19406b7
remove getNumWorkersPerProcess > 1 assert
chaokunyang Sep 8, 2020
c76ad5d
lint
chaokunyang Sep 8, 2020
e401318
fix ray init
chaokunyang Sep 8, 2020
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 ArgByRef
  • Loading branch information
chaokunyang committed Sep 4, 2020
commit 957c231572f56441e793b70dd2e75bd7b6b0a5f0
2 changes: 1 addition & 1 deletion src/ray/common/task/task_spec.cc
Original file line number Diff line number Diff line change
Expand Up @@ -120,7 +120,7 @@ ObjectID TaskSpecification::ReturnId(size_t return_index) const {
}

bool TaskSpecification::ArgByRef(size_t arg_index) const {
return message_->args(arg_index).object_ref().object_id() != "";
return message_->args(arg_index).object_ref().has_object_ref();
}

ObjectID TaskSpecification::ArgId(size_t arg_index) const {
Expand Down
1 change: 1 addition & 0 deletions src/ray/ray_exported_symbols.lds
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,7 @@
*ray*TaskID*
*ray*ActorID*
*ray*ObjectID*
*ray*ObjectReference*
# Others
*ray*CoreWorker*
*PyInit*
Expand Down
1 change: 1 addition & 0 deletions src/ray/ray_version_script.lds
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@ VERSION_1.0 {
*ray*TaskID*;
*ray*ActorID*;
*ray*ObjectID*;
*ray*ObjectReference*;
# Others
*ray*CoreWorker*;
*PyInit*;
Expand Down