Merge "Ignore deleted nodes when looking for lost params"

2022-04-29 00:04:38 +00:00
parent 3192f4d2eb 9764c9d131
commit a348a31648
1 changed files with 3 additions and 0 deletions
--- a/zuul/zk/job_request_queue.py
+++ b/zuul/zk/job_request_queue.py
@@ -528,6 +528,9 @@ class JobRequestQueue(ZooKeeperSimpleBase):
        for data_id in self.kazoo_client.get_children(self.PARAM_ROOT):
            data_path = self._getParamsPath(data_id)
            data_zstat = self.kazoo_client.exists(data_path)
+            if not data_zstat:
+                # Node was deleted in the meantime
+                continue
            if now - data_zstat.mtime > age:
                data_nodes[data_id] = data_path