Add FinePerformanceMetrics dashboard test

Author: milesgranger

distributed/comm/tests/test_ucx.py

@@ -41,7 +41,7 @@ def test_registered(ucx_loop):
 
 
 async def get_comm_pair(
-    listen_addr="ucx://" + HOST, listen_args=None, connect_args=None, **kwargs
+    listen_addr=f"ucx://{HOST}", listen_args=None, connect_args=None, **kwargs
 ):
     listen_args = listen_args or {}
     connect_args = connect_args or {}

distributed/dashboard/tests/test_scheduler_bokeh.py

@@ -28,6 +28,7 @@
     Contention,
     CurrentLoad,
     Events,
+    FinePerformanceMetrics,
     Hardware,
     MemoryByKey,
     MemoryColor,
@@ -328,6 +329,21 @@ async def test_WorkersMemory(c, s, a, b):
     assert all(d["width"])
 
 
+@gen_cluster(client=True)
+async def test_FinePerformanceMetrics(c, s, a, b):
+    cl = FinePerformanceMetrics(s)
+
+    futures = c.map(slowinc, range(10), delay=0.001)
+    await wait(futures)
+    await asyncio.sleep(0.5)  # wait for metrics to arrive
+
+    cl.update()
+    d = dict(cl.metrics_by_prefix_and_activity.data)
+    ops = cl.metrics_by_prefix_and_activity.operations.copy()
+    assert ops  # Have some activities, 'deserialize', 'execution', etc
+    assert d  # Have metrics
+
+
 @gen_cluster(client=True)
 async def test_ClusterMemory(c, s, a, b):
     cl = ClusterMemory(s)