diff --git a/distributed/scheduler.py b/distributed/scheduler.py index 77a9be2f6d..43e54e47c2 100644 --- 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 index 724a738777..6fd59e49d7 100644 --- 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):