Compose/frigate
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix syntax error and redundant connection call in MQTT client

Browse Source 
- Removed duplicate `async` keyword from `on_connect` method.
- Removed redundant `await client.connect()` to avoid double connection attempt.
This commit is contained in:
Marcus Brown
2024-10-20 18:50:11 +11:00
parent 564c963af1
commit 998ad12e61
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
dayglo_detector/dayglo_detector.py
+1 -2
View File
@@ -33,7 +33,7 @@ initial_snapshot_processed = False
connected_once = False connected_once = False
class DaygloDetectorMQTTClient(MQTTClient): class DaygloDetectorMQTTClient(MQTTClient):
async async def on_connect(self, client, flags, rc, properties): async def on_connect(self, client, flags, rc, properties):
global connected_once global connected_once
if rc == 0 and not connected_once: if rc == 0 and not connected_once:
print("Connected successfully to MQTT broker") print("Connected successfully to MQTT broker")
@@ -133,7 +133,6 @@ async def main():
client = DaygloDetectorMQTTClient("dayglo_detector") client = DaygloDetectorMQTTClient("dayglo_detector")
client.set_auth_credentials(MQTT_USERNAME, MQTT_PASSWORD) client.set_auth_credentials(MQTT_USERNAME, MQTT_PASSWORD)
await client.connect(MQTT_BROKER, MQTT_PORT, keepalive=60)
await client.connect(MQTT_BROKER, MQTT_PORT, keepalive=60) await client.connect(MQTT_BROKER, MQTT_PORT, keepalive=60)
await asyncio.get_event_loop().create_future() await asyncio.get_event_loop().create_future()