Refactor occupancy (#7075)

Co-authored-by: fjetter <fjetter@users.noreply.github.com> Co-authored-by: Gabe Joseph <gjoseph92@gmail.com>
dask · Oct 7, 2022 · 07e2259 · 07e2259
1 parent 2196966
commit 07e2259
Show file tree

Hide file tree

Showing 8 changed files with 322 additions and 285 deletions.
diff --git a/distributed/dashboard/components/scheduler.py b/distributed/dashboard/components/scheduler.py
@@ -1973,7 +1973,7 @@ def update(self):
         current = len(self.scheduler.events["stealing"])
         n = current - self.last
 
-        log = [log[-i][1] for i in range(1, n + 1) if isinstance(log[-i][1], list)]
+        log = [log[-i][1][1] for i in range(1, n + 1) if log[-i][1][0] == "request"]
         self.last = current
 
         if log: