Human-readable formatting for disk I/O and renaming to diff net and disk
@@ -3366,8 +3366,10 @@ class WorkerTable(DashboardComponent):
"memory_unmanaged_recent": "unmanaged recent",
"memory_spilled": "spilled",
"num_fds": "# fds",
- "read_bytes": "read",
- "write_bytes": "write",
+ "read_bytes": "net read",
+ "write_bytes": "net write",
+ "read_bytes_disk": "disk read",
+ "write_bytes_disk": "disk write",
}
self.source = ColumnDataSource({k: [] for k in self.names})
@@ -3390,6 +3392,8 @@ class WorkerTable(DashboardComponent):
"write_bytes": NumberFormatter(format="0 b"),
"num_fds": NumberFormatter(format="0"),
"nthreads": NumberFormatter(format="0"),
+ "read_bytes_disk": NumberFormatter(format="0 b"),
+ "write_bytes_disk": NumberFormatter(format="0 b"),
}
table = DataTable(
@@ -3420,6 +3424,12 @@ class WorkerTable(DashboardComponent):
index_position=None,
)
+ for name in extra_names:
+ if name in formatters:
+ extra_table.columns[extra_names.index(name)].formatter = formatters[
+ name
+ ]
+
hover = HoverTool(
point_policy="follow_mouse",
tooltips="""
