mirror of
https://github.com/wassname/ray.git
synced 2026-07-01 14:19:38 +08:00
[Dashboard] New dashboard view data doesn't exist. (#12129)
* Fix. * Fix the issue.
This commit is contained in:
@@ -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
|
||||
|
||||
Reference in New Issue
Block a user