Add time started to scheduler info (#4425)

dask · Jan 13, 2021 · da3d2a4 · da3d2a4
1 parent 74e8dc6
commit da3d2a4
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/distributed/scheduler.py b/distributed/scheduler.py
@@ -1963,6 +1963,7 @@ def identity(self, comm=None):
             "id": str(self.id),
             "address": self.address,
             "services": {key: v.port for (key, v) in self.services.items()},
+            "started": self.time_started,
             "workers": {
                 worker.address: worker.identity() for worker in self.workers.values()
             },

diff --git a/distributed/tests/test_client.py b/distributed/tests/test_client.py
@@ -3789,6 +3789,7 @@ def test_scheduler_info(c):
     info = c.scheduler_info()
     assert isinstance(info, dict)
     assert len(info["workers"]) == 2
+    assert isinstance(info["started"], float)
 
 
 def test_write_scheduler_file(c):