mirror of
https://github.com/wassname/ray.git
synced 2026-07-01 04:50:40 +08:00
Remove unnecessary handling of setproctitle and psutil. (#7702)
This commit is contained in:
@@ -41,10 +41,8 @@ class RayTaskError(RayError):
|
||||
"""Initialize a RayTaskError."""
|
||||
if proctitle:
|
||||
self.proctitle = proctitle
|
||||
elif setproctitle:
|
||||
self.proctitle = setproctitle.getproctitle()
|
||||
else:
|
||||
self.proctitle = "ray_worker"
|
||||
self.proctitle = setproctitle.getproctitle()
|
||||
self.pid = pid or os.getpid()
|
||||
self.ip = ip or ray.services.get_node_ip_address()
|
||||
self.function_name = function_name
|
||||
|
||||
@@ -1102,7 +1102,7 @@ def start_dashboard(require_webui,
|
||||
webui_dependencies_present = False
|
||||
warning_message = (
|
||||
"Failed to start the dashboard. The dashboard requires Python 3 "
|
||||
"as well as 'pip install aiohttp psutil setproctitle grpcio'.")
|
||||
"as well as 'pip install aiohttp grpcio'.")
|
||||
if require_webui:
|
||||
raise ImportError(warning_message)
|
||||
else:
|
||||
|
||||
+3
-12
@@ -677,12 +677,6 @@ def init(address=None,
|
||||
else:
|
||||
driver_mode = SCRIPT_MODE
|
||||
|
||||
if setproctitle is None:
|
||||
logger.warning(
|
||||
"WARNING: Not updating worker name since `setproctitle` is not "
|
||||
"installed. Install this with `pip install setproctitle` "
|
||||
"(or ray[debug]) to enable monitoring of worker processes.")
|
||||
|
||||
if global_worker.connected:
|
||||
if ignore_reinit_error:
|
||||
logger.error("Calling ray.init() again after it has already been "
|
||||
@@ -1142,8 +1136,7 @@ def connect(node,
|
||||
job_id = JobID.nil()
|
||||
# TODO(qwang): Rename this to `worker_id_str` or type to `WorkerID`
|
||||
worker.worker_id = _random_string()
|
||||
if setproctitle:
|
||||
setproctitle.setproctitle("ray::IDLE")
|
||||
setproctitle.setproctitle("ray::IDLE")
|
||||
elif mode is LOCAL_MODE:
|
||||
if job_id is None:
|
||||
job_id = JobID.from_int(random.randint(1, 65535))
|
||||
@@ -1369,11 +1362,9 @@ def disconnect(exiting_interpreter=False):
|
||||
|
||||
@contextmanager
|
||||
def _changeproctitle(title, next_title):
|
||||
if setproctitle:
|
||||
setproctitle.setproctitle(title)
|
||||
setproctitle.setproctitle(title)
|
||||
yield
|
||||
if setproctitle:
|
||||
setproctitle.setproctitle(next_title)
|
||||
setproctitle.setproctitle(next_title)
|
||||
|
||||
|
||||
def register_custom_serializer(cls,
|
||||
|
||||
Reference in New Issue
Block a user