diff options
| author | Zuul <zuul@review.opendev.org> | 2022-04-29 00:04:38 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2022-04-29 00:04:38 +0000 |
| commit | a348a3164829a9d7a37bd22f1497f278880abc9f (patch) | |
| tree | 6e5e0dbbb95e0733ade72d62ebc061c1869c5733 /zuul/zk | |
| parent | 3192f4d2eba7e671b69970febc7d8564a698a086 (diff) | |
| parent | 9764c9d1311d20452f9a8f878279fc19f6bcc0c5 (diff) | |
| download | zuul-a348a3164829a9d7a37bd22f1497f278880abc9f.tar.gz | |
Merge "Ignore deleted nodes when looking for lost params"
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 |