diff options
| author | Zuul <zuul@review.opendev.org> | 2021-05-21 19:44:42 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2021-05-21 19:44:42 +0000 |
| commit | 7b77e5b585a0a58567b027c78e7d04db892f0cba (patch) | |
| tree | e56cd7fe221c44e4a2420ad7e67833c33e92191b /zuul/driver/gerrit | |
| parent | 40bfed86f7926a951c30cd5b4b8ab89664bbb4db (diff) | |
| parent | 5bc219d5cd2677798b2fde3bf5f2042c4d6be716 (diff) | |
| download | zuul-7b77e5b585a0a58567b027c78e7d04db892f0cba.tar.gz | |
Merge "Allow monitoring length of connection event queues"
Diffstat (limited to 'zuul/driver/gerrit')
| -rw-r--r-- | zuul/driver/gerrit/gerritconnection.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/zuul/driver/gerrit/gerritconnection.py b/zuul/driver/gerrit/gerritconnection.py index f1bbcd9ad..5de8358a8 100644 --- a/zuul/driver/gerrit/gerritconnection.py +++ b/zuul/driver/gerrit/gerritconnection.py @@ -1524,6 +1524,9 @@ class GerritConnection(BaseConnection): self._stop_ref_watcher_thread() self._stop_event_connector() + def getEventQueue(self): + return getattr(self, "event_queue", None) + def _stop_watcher_thread(self): if self.watcher_thread: self.watcher_thread.stop() |