@@ -129,7 +129,12 @@ def mqtt_loop(self, *args: int, suppress_mqtt_errors: bool = True, **kwargs: int
129
129
if self ._mqtt_client is not None :
130
130
self ._mqtt_client .loop (* args , ** kwargs )
131
131
132
- def mqtt_publish (self , * args : Union [str , int , float ], suppress_mqtt_errors : bool = True , ** kwargs : Union [str , int , float ]):
132
+ def mqtt_publish (
133
+ self ,
134
+ * args : Union [str , int , float ],
135
+ suppress_mqtt_errors : bool = True ,
136
+ ** kwargs : Union [str , int , float ]
137
+ ):
133
138
"""Publish to MQTT"""
134
139
self ._get_mqtt_client ()
135
140
if suppress_mqtt_errors :
@@ -142,7 +147,9 @@ def mqtt_publish(self, *args: Union[str, int, float], suppress_mqtt_errors: bool
142
147
if self ._mqtt_client is not None :
143
148
self ._mqtt_client .publish (* args , ** kwargs )
144
149
145
- def mqtt_connect (self , * args : Union [bool , str , int ], ** kwargs : Union [bool , str , int ]):
150
+ def mqtt_connect (
151
+ self , * args : Union [bool , str , int ], ** kwargs : Union [bool , str , int ]
152
+ ):
146
153
"""Connect to MQTT"""
147
154
self ._get_mqtt_client ()
148
155
if self ._mqtt_client is not None :
0 commit comments