Skip to content

Commit

Permalink
[CoreWorker][deprecate run_function_on_all_workers 2/n] announcing de…
Browse files Browse the repository at this point in the history
…precation of run_function_on_all_workers (#31528)

Warn user that run_function_on_all_workers will be deleted by Ray 2.4. Ray core no longer uses this function after #31383
Signed-off-by: Chen Shen <scv119@gmail.com>
Co-authored-by: Cade Daniel <edacih@gmail.com>
  • Loading branch information
scv119 authored and AmeerHajAli committed Jan 12, 2023
1 parent 5cb4d73 commit 141d185
Showing 1 changed file with 8 additions and 1 deletion.
9 changes: 8 additions & 1 deletion python/ray/_private/worker.py
Original file line number Diff line number Diff line change
Expand Up @@ -687,7 +687,14 @@ def get_objects(self, object_refs: list, timeout: Optional[float] = None):
debugger_breakpoint,
)

@Deprecated
@Deprecated(
message="This function is deprecated and will be removed by Ray 2.4. "
"Please use Runtime Environments "
f"https://docs.ray.io/en/{get_ray_doc_version()}/ray-core"
"/handling-dependencies.html "
"to manage dependencies in workers.",
warning=True,
)
def run_function_on_all_workers(self, function: callable):
"""This function has been deprecated given the following issues:
- no guarantee that the function run before the remote function run.
Expand Down

0 comments on commit 141d185

Please sign in to comment.