From 1c61f677ba7f1df8d2b76c112fe23383d3bd6037 Mon Sep 17 00:00:00 2001 From: Jakub Kicinski Date: Wed, 29 Nov 2023 14:45:56 -0800 Subject: [PATCH] tester: log qsize() in the worker Log workers backlog size for the benefit of the status page. Signed-off-by: Jakub Kicinski --- core/tester.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/core/tester.py b/core/tester.py index 04b07f9..f2b652e 100644 --- a/core/tester.py +++ b/core/tester.py @@ -83,11 +83,13 @@ def run(self) -> None: s = self.queue.get() if s is None: continue + + core.log(f"Tester commencing with backlog of {self.queue.qsize()}") self.test_series(self.tree, s) self.done_queue.put(s) # If we're the last worker with work to do - let the poller run - core.log(f"Checking barrier {self.barrier.n_waiting}/{self.barrier.parties} ") + core.log(f"Checking barrier {self.barrier.n_waiting}/{self.barrier.parties} {self.queue.qsize()}") if self.barrier.parties == self.barrier.n_waiting + 1: break