[core] replace node_manager_client with raylet_client_lib#56261
[core] replace node_manager_client with raylet_client_lib#56261dayshah merged 8 commits intoray-project:masterfrom
Conversation
2e8a95a to
e2cbb7c
Compare
Signed-off-by: Rueian <rueian@anyscale.com>
e2cbb7c to
486c719
Compare
Signed-off-by: Rueian <rueian@anyscale.com>
88c94a0 to
3bb3049
Compare
3bb3049 to
27726a4
Compare
| retryable_grpc_client_, | ||
| ray::rpc, | ||
| NodeManagerService, | ||
| ReturnWorkerLease, |
There was a problem hiding this comment.
ReturnWorkerLease should be called with retryable_grpc_client_ according to the original node_manager_client.
| INVOKE_RETRYABLE_RPC_CALL_FULL(retryable_grpc_client_, | ||
| ray::rpc, | ||
| NodeManagerService, | ||
| CancelWorkerLease, |
There was a problem hiding this comment.
CancelWorkerLease should be called with retryable_grpc_client_ according to the original node_manager_client.
src/ray/rpc/grpc_client.h
Outdated
| &SERVICE_NAMESPACE::SERVICE::Stub::PrepareAsync##METHOD, \ | ||
| request, \ | ||
| callback, \ | ||
| #SERVICE ".grpc_client." #METHOD, \ |
There was a problem hiding this comment.
A new INVOKE_RPC_CALL_FULL macro is created to keep this call_name (#SERVICE ".grpc_client." #METHOD) argument unchanged, but allow specifying SERVICE_NAMESPACE from the caller side.
src/ray/rpc/retryable_grpc_client.h
Outdated
| SERVICE_NAMESPACE::METHOD##Reply>( \ | ||
| &SERVICE_NAMESPACE::SERVICE::Stub::PrepareAsync##METHOD, \ | ||
| rpc_client, \ | ||
| #SERVICE ".grpc_client." #METHOD, \ |
There was a problem hiding this comment.
Same as INVOKE_RETRYABLE_RPC_CALL_FULL macro. This is created to keep this call_name (#SERVICE ".grpc_client." #METHOD) argument unchanged, but allow specifying SERVICE_NAMESPACE from the caller side.
| request, | ||
| callback, | ||
| grpc_client_, | ||
| /*method_timeout_ms*/ -1); |
There was a problem hiding this comment.
can you just move raylet_client and raylet_client_pool into a raylet folder inside rpc and put it inside the ray::rpc namespace so you don't need this special rpc naming macro and it stays consistent with the core_worker_client
There was a problem hiding this comment.
Yes! I have moved the entire raylet_client to under ray/rpc/raylet.
src/ray/raylet_client/BUILD.bazel
Outdated
| ":raylet_client_interface", | ||
| "//src/ray/common:task_common", | ||
| "//src/ray/flatbuffers:node_manager_generated", | ||
| "//src/ray/gcs/gcs_client:gcs_client_lib", |
There was a problem hiding this comment.
What is gcs_client_lib needed here for?
There was a problem hiding this comment.
Oh, thanks for pointing that out. I removed all the unnecessary deps.
Signed-off-by: Rueian <rueian@anyscale.com>
Signed-off-by: Rueian <rueian@anyscale.com>
Signed-off-by: Rueian <rueian@anyscale.com>
Signed-off-by: Rueian <rueian@anyscale.com>
a5f5c93 to
db921c1
Compare
Signed-off-by: Rueian <rueian@anyscale.com>
db921c1 to
f24bc5d
Compare
…t#56261) Signed-off-by: Rueian <rueian@anyscale.com> Signed-off-by: sampan <sampan@anyscale.com>
|
great stuff @rueian!! |
…t#56261) Signed-off-by: Rueian <rueian@anyscale.com> Signed-off-by: jugalshah291 <shah.jugal291@gmail.com>
…t#56261) Signed-off-by: Rueian <rueian@anyscale.com> Signed-off-by: yenhong.wong <yenhong.wong@grabtaxi.com>
…t#56261) Signed-off-by: Rueian <rueian@anyscale.com> Signed-off-by: zac <zac@anyscale.com>
Signed-off-by: Rueian <rueian@anyscale.com> Signed-off-by: Douglas Strodtman <douglas@anyscale.com>
…t#56261) Signed-off-by: Rueian <rueian@anyscale.com>
…t#56261) Signed-off-by: Rueian <rueian@anyscale.com>
Why are these changes needed?
This is the follow-up for #56101.
No behavior changes in this PR.
Related issue number
Checks
git commit -s) in this PR.scripts/format.shto lint the changes in this PR.method in Tune, I've added it in
doc/source/tune/api/under thecorresponding
.rstfile.