From e03f687b847ff49d3a2c92e49332f1b39c4d452d Mon Sep 17 00:00:00 2001 From: ijrsvt Date: Fri, 3 Apr 2020 17:54:15 -0700 Subject: [PATCH] Cleaning up remaining Local Mode Code (#7865) --- python/ray/experimental/internal_kv.py | 7 ------- python/ray/internal/internal_api.py | 4 ---- python/ray/node.py | 14 -------------- 3 files changed, 25 deletions(-) diff --git a/python/ray/experimental/internal_kv.py b/python/ray/experimental/internal_kv.py index 138071f50..1bdd910a6 100644 --- a/python/ray/experimental/internal_kv.py +++ b/python/ray/experimental/internal_kv.py @@ -12,8 +12,6 @@ def _internal_kv_get(key): """Fetch the value of a binary key.""" worker = ray.worker.global_worker - if worker.mode == ray.worker.LOCAL_MODE: - return _local.get(key) return worker.redis_client.hget(key, "value") @@ -28,11 +26,6 @@ def _internal_kv_put(key, value, overwrite=False): """ worker = ray.worker.global_worker - if worker.mode == ray.worker.LOCAL_MODE: - exists = key in _local - if not exists or overwrite: - _local[key] = value - return exists if overwrite: updated = worker.redis_client.hset(key, "value", value) diff --git a/python/ray/internal/internal_api.py b/python/ray/internal/internal_api.py index 013fb880b..208e8250f 100644 --- a/python/ray/internal/internal_api.py +++ b/python/ray/internal/internal_api.py @@ -69,10 +69,6 @@ def free(object_ids, local_only=False, delete_creating_tasks=False): raise TypeError("Attempting to call `free` on the value {}, " "which is not an ray.ObjectID.".format(object_id)) - if ray.worker._mode() == ray.worker.LOCAL_MODE: - worker.local_mode_manager.free(object_ids) - return - worker.check_connected() with profiling.profile("ray.free"): if len(object_ids) == 0: diff --git a/python/ray/node.py b/python/ray/node.py index e885258fe..226a74f3e 100644 --- a/python/ray/node.py +++ b/python/ray/node.py @@ -921,17 +921,3 @@ class Node: True if any process that wasn't explicitly killed is still alive. """ return not any(self.dead_processes()) - - -# TODO(ilr) Remove this soon -class LocalNode: - """Imitate the node that manages the processes in local mode.""" - - def kill_all_processes(self, *args, **kwargs): - """Kill all of the processes.""" - pass # Keep this function empty because it will be used in worker.py - - @property - def address_info(self): - """Get a dictionary of addresses.""" - return {} # Return a null dict.