From 5fb410cfbf2e42d7db61ffeed9fa3b07b21b14ce Mon Sep 17 00:00:00 2001 From: SangBin Cho Date: Thu, 19 Nov 2020 11:04:59 -0800 Subject: [PATCH] [Dashboard] New dashboard view data doesn't exist. (#12129) * Fix. * Fix the issue. --- dashboard/datacenter.py | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/dashboard/datacenter.py b/dashboard/datacenter.py index cb699a39f..4e6b9ce08 100644 --- a/dashboard/datacenter.py +++ b/dashboard/datacenter.py @@ -95,9 +95,7 @@ class DataOrganizer: workers = [] node_ip = DataSource.node_id_to_ip[node_id] node_logs = DataSource.ip_and_pid_to_logs.get(node_ip, {}) - logger.error(node_logs) node_errs = DataSource.ip_and_pid_to_errors.get(node_ip, {}) - logger.error(node_errs) node_physical_stats = DataSource.node_physical_stats.get(node_id, {}) node_stats = DataSource.node_stats.get(node_id, {}) # Merge coreWorkerStats (node stats) to workers (node physical stats) @@ -112,7 +110,6 @@ class DataOrganizer: for worker in node_physical_stats.get("workers", []): worker = dict(worker) pid = worker["pid"] - logger.error(f"pid={pid}") worker["logCount"] = len(node_logs.get(str(pid), [])) worker["errorCount"] = len(node_errs.get(str(pid), [])) worker["coreWorkerStats"] = pid_to_worker_stats.get(pid, []) @@ -145,8 +142,9 @@ class DataOrganizer: node_stats.pop("coreWorkersStats", None) + view_data = node_stats.get("viewData", []) ray_stats = cls._extract_view_data( - node_stats["viewData"], + view_data, {"object_store_used_memory", "object_store_available_memory"}) node_info = node_physical_stats