summaryrefslogtreecommitdiff
path: root/zuul/driver/mqtt/mqttconnection.py
diff options
context:
space:
mode:
authorJames E. Blair <jim@acmegating.com>2022-01-06 16:03:09 -0800
committerJames E. Blair <jim@acmegating.com>2022-01-27 12:19:11 -0800
commit29fbee73753c8f0febf913fb79d271287201170d (patch)
tree20a1a615199c99e56e74aa45d1641a5fd9d90302 /zuul/driver/mqtt/mqttconnection.py
parent4c0fef8c1ef5b011f840b3fd4958e1e0e61c8150 (diff)
downloadzuul-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.py2
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(