@@ -291,8 +291,8 @@ async def discovery_task(self, interval=0.100):
291
291
292
292
if lastval_record := self .records .pop ("r:m" , None ):
293
293
lastval_record .add_to_pack (self .senmlpack )
294
- self .mqtt .subscribe (self .create_topic ("shadow" , "i" ))
295
- self .mqtt .publish (self .create_topic ("shadow" , "o" ), self .senmlpack .to_cbor (), qos = True )
294
+ self .mqtt .subscribe (self .create_topic ("shadow" , "i" ), qos = 1 )
295
+ self .mqtt .publish (self .create_topic ("shadow" , "o" ), self .senmlpack .to_cbor (), qos = 1 )
296
296
logging .info ("Device configured via discovery protocol." )
297
297
await asyncio .sleep (interval )
298
298
@@ -308,7 +308,7 @@ async def mqtt_task(self, interval=0.100):
308
308
logging .debug ("Pushing records to Arduino IoT cloud:" )
309
309
for record in self .senmlpack ._data :
310
310
logging .debug (f" ==> record: { record .name } value: { str (record .value )[:48 ]} ..." )
311
- self .mqtt .publish (self .topic_out , self .senmlpack .to_cbor (), qos = True )
311
+ self .mqtt .publish (self .topic_out , self .senmlpack .to_cbor (), qos = 1 )
312
312
self .last_ping = timestamp ()
313
313
elif self .keepalive and (timestamp () - self .last_ping ) > self .keepalive :
314
314
self .mqtt .ping ()
0 commit comments