@@ -1215,17 +1215,17 @@ def _publish_data(self, data, topic, qos, timeout=DEFAULT_TIMEOUT, device=None,
12151215 return self ._send_request (TBSendMethod .PUBLISH , {"topic" : topic , "payload" : data , "qos" : qos }, timeout ,
12161216 device = device , msg_rate_limit = msg_rate_limit , dp_rate_limit = dp_rate_limit )
12171217
1218- def send_telemetry (self , telemetry , quality_of_service = None , wait_for_publish = True ):
1218+ def send_telemetry (self , telemetry , quality_of_service = None , timeout = DEFAULT_TIMEOUT ):
12191219 """Send telemetry to ThingsBoard. The telemetry can be a single dictionary or a list of dictionaries."""
12201220 quality_of_service = quality_of_service if quality_of_service is not None else self .quality_of_service
12211221 if not isinstance (telemetry , list ) and not (isinstance (telemetry , dict ) and telemetry .get ("ts" ) is not None ):
12221222 telemetry = [telemetry ]
1223- return self ._publish_data (telemetry , TELEMETRY_TOPIC , quality_of_service , wait_for_publish )
1223+ return self ._publish_data (telemetry , TELEMETRY_TOPIC , quality_of_service , timeout = timeout )
12241224
1225- def send_attributes (self , attributes , quality_of_service = None , wait_for_publish = True ):
1225+ def send_attributes (self , attributes , quality_of_service = None , timeout = DEFAULT_TIMEOUT ):
12261226 """Send attributes to ThingsBoard. The attributes can be a single dictionary or a list of dictionaries."""
12271227 quality_of_service = quality_of_service if quality_of_service is not None else self .quality_of_service
1228- return self ._publish_data (attributes , ATTRIBUTES_TOPIC , quality_of_service , wait_for_publish )
1228+ return self ._publish_data (attributes , ATTRIBUTES_TOPIC , quality_of_service , timeout = timeout )
12291229
12301230 def unsubscribe_from_attribute (self , subscription_id ):
12311231 """Unsubscribe from attribute updates for subscription_id."""
0 commit comments