diff options
author | James E. Blair <jim@acmegating.com> | 2022-01-06 16:03:09 -0800 |
---|---|---|
committer | James E. Blair <jim@acmegating.com> | 2022-01-27 12:19:11 -0800 |
commit | 29fbee73753c8f0febf913fb79d271287201170d (patch) | |
tree | 20a1a615199c99e56e74aa45d1641a5fd9d90302 /zuul/driver/mqtt/mqttconnection.py | |
parent | 4c0fef8c1ef5b011f840b3fd4958e1e0e61c8150 (diff) | |
download | zuul-29fbee73753c8f0febf913fb79d271287201170d.tar.gz |
Add a model API version
This is a framework for making upgrades to the ZooKeeper data model
in a manner that can support a rolling Zuul system upgrade.
Change-Id: Iff09c95878420e19234908c2a937e9444832a6ec
Diffstat (limited to 'zuul/driver/mqtt/mqttconnection.py')
-rw-r--r-- | zuul/driver/mqtt/mqttconnection.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/zuul/driver/mqtt/mqttconnection.py b/zuul/driver/mqtt/mqttconnection.py index d75b7a3a2..7f221282f 100644 --- a/zuul/driver/mqtt/mqttconnection.py +++ b/zuul/driver/mqtt/mqttconnection.py @@ -62,7 +62,7 @@ class MQTTConnection(BaseConnection): def _on_disconnect(self, client, userdata, rc): self.connected = False - def onLoad(self, zk_client): + def onLoad(self, zk_client, component_registry): self.log.debug("Starting MQTT Connection") try: self.client.connect( |