Skip to content

Commit c739af5

Browse files
committed
Fix protocol arg (same as prior sensor change) for publish action
1 parent f1d60f9 commit c739af5

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

actions/publish.py

+2-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
from st2common.runners.base_action import Action
2+
import paho.mqtt.client as paho
23
import paho.mqtt.publish as publish
34

45

@@ -53,4 +54,4 @@ def run(self, topic, message=None, qos=0, retain=False):
5354
hostname=self._hostname, port=self._port,
5455
client_id=self._client_id, keepalive=60,
5556
auth=self._auth_payload, tls=self._ssl_payload,
56-
protocol=self._protocol)
57+
protocol=getattr(paho, self._protocol))

0 commit comments

Comments
 (0)