diff --git a/python/ray/state.py b/python/ray/state.py index 0bc97656e..02748c45c 100644 --- a/python/ray/state.py +++ b/python/ray/state.py @@ -415,7 +415,7 @@ class GlobalState: entry = gcs_utils.JobTableData.FromString(gcs_entry.entries[i]) assert entry.job_id == job_id.binary() job_info["JobID"] = job_id.hex() - job_info["NodeManagerAddress"] = entry.node_manager_address + job_info["DriverIPAddress"] = entry.driver_ip_address job_info["DriverPid"] = entry.driver_pid if entry.is_dead: job_info["StopTime"] = entry.timestamp @@ -431,7 +431,7 @@ class GlobalState: Information about the Ray jobs in the cluster, namely a list of dicts with keys: - "JobID" (identifier for the job), - - "NodeManagerAddress" (IP address of the driver for this job), + - "DriverIPAddress" (IP address of the driver for this job), - "DriverPid" (process ID of the driver for this job), - "StartTime" (UNIX timestamp of the start time of this job), - "StopTime" (UNIX timestamp of the stop time of this job, if any) @@ -991,7 +991,7 @@ def jobs(): Returns: Information from the job table, namely a list of dicts with keys: - "JobID" (identifier for the job), - - "NodeManagerAddress" (IP address of the driver for this job), + - "DriverIPAddress" (IP address of the driver for this job), - "DriverPid" (process ID of the driver for this job), - "StartTime" (UNIX timestamp of the start time of this job), - "StopTime" (UNIX timestamp of the stop time of this job, if any) diff --git a/python/ray/tests/test_advanced_3.py b/python/ray/tests/test_advanced_3.py index 451ca1492..2776a14ab 100644 --- a/python/ray/tests/test_advanced_3.py +++ b/python/ray/tests/test_advanced_3.py @@ -159,7 +159,7 @@ def test_global_state_api(shutdown_only): assert len(job_table) == 1 assert job_table[0]["JobID"] == job_id.hex() - assert job_table[0]["NodeManagerAddress"] == node_ip_address + assert job_table[0]["DriverIPAddress"] == node_ip_address # TODO(rkn): Pytest actually has tools for capturing stdout and stderr, so we