diff options
| author | Zuul <zuul@review.opendev.org> | 2022-08-19 21:33:58 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2022-08-19 21:33:58 +0000 |
| commit | 7491e081bd1e08defd98245489e50604d317b6aa (patch) | |
| tree | ea14483edd1880b77341ce8b04556930146da6c3 /zuul/zk | |
| parent | 61a5b7f0934aec9380a80ddca70c24555f472caf (diff) | |
| parent | e6530d11d058e50c41872f3c2c9ac286b57ed70e (diff) | |
| download | zuul-7491e081bd1e08defd98245489e50604d317b6aa.tar.gz | |
Merge "Reduce redundant Gerrit queries"
Diffstat (limited to 'zuul/zk')
| -rw-r--r-- | zuul/zk/event_queues.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/zuul/zk/event_queues.py b/zuul/zk/event_queues.py index 52ffd582e..ad7529791 100644 --- a/zuul/zk/event_queues.py +++ b/zuul/zk/event_queues.py @@ -909,7 +909,7 @@ class ConnectionEventQueue(ZooKeeperEventQueue): self._put({'event_data': data}) def __iter__(self): - for data, ack_ref, _ in self._iterEvents(): + for data, ack_ref, zstat in self._iterEvents(): if not data: self.log.warning("Malformed event found: %s", data) self._remove(ack_ref.path) @@ -918,6 +918,7 @@ class ConnectionEventQueue(ZooKeeperEventQueue): event = model.ConnectionEvent.fromDict( data.get('event_data', data)) event.ack_ref = ack_ref + event.zuul_event_ltime = zstat.creation_transaction_id yield event |