diff options
Diffstat (limited to 'zuul/zk')
| -rw-r--r-- | zuul/zk/job_request_queue.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/zuul/zk/job_request_queue.py b/zuul/zk/job_request_queue.py index bd2b05f32..902afce2a 100644 --- 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 |