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][deprecate run_function_on_all_workers 3/n] delete run_function_on_all_workers #30895

Merged
merged 13 commits into from
Jun 8, 2023
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
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
update
  • Loading branch information
scv119 committed Jun 7, 2023
commit 07cdc08503493d58d3e6fc0e9eaf447254dd32d6
2 changes: 0 additions & 2 deletions python/ray/_private/import_thread.py
Original file line number Diff line number Diff line change
@@ -1,10 +1,8 @@
import logging
import threading
import traceback
from collections import defaultdict

import ray
import ray._private.profiling as profiling
from ray import JobID
from ray import cloudpickle as pickle
from ray._private import ray_constants
Expand Down
6 changes: 2 additions & 4 deletions python/ray/_private/worker.py
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
import atexit
import faulthandler
import functools
import hashlib
import inspect
import io
import json
Expand Down Expand Up @@ -56,13 +55,12 @@

# Ray modules
import ray.actor
import ray.cloudpickle as pickle
import ray.job_config
import ray.remote_function
from ray import ActorID, JobID, Language, ObjectRef
from ray._private import ray_option_utils
from ray._private.client_mode_hook import client_mode_hook
from ray._private.function_manager import FunctionActorManager, make_function_table_key
from ray._private.function_manager import FunctionActorManager

from ray._private.inspect_util import is_cython
from ray._private.ray_logging import (
Expand All @@ -76,7 +74,7 @@
from ray._private.runtime_env.working_dir import upload_working_dir_if_needed
from ray._private.runtime_env.setup_hook import upload_worker_setup_hook_if_needed
from ray._private.storage import _load_class
from ray._private.utils import check_oversized_function, get_ray_doc_version
from ray._private.utils import get_ray_doc_version
from ray.exceptions import ObjectStoreFullError, RayError, RaySystemError, RayTaskError
from ray.experimental.internal_kv import (
_initialize_internal_kv,
Expand Down
Loading