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