Fix(mqtt): Reformatted

OFFIS-DAI · Feb 10, 2025 · 4b085a8 · 4b085a8
1 parent c576f24
commit 4b085a8
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/mango/container/mqtt.py b/mango/container/mqtt.py
@@ -263,7 +263,7 @@ def on_discon(client, userdata, disconnect_flags, reason_code, properties):
                 logger.debug("Successfully disconnected from broker.")
 
         self.mqtt_client.on_disconnect = on_discon
-        
+
         def process_sub_request(mid):
             self.pending_sub_request[mid].set_result(0)
 
@@ -440,9 +440,9 @@ async def subscribe_for_agent(self, *, aid: str, topic: str, qos: int = 2) -> bo
         result, mid = self.mqtt_client.subscribe(topic, qos=qos)
 
         if result != paho.MQTT_ERR_SUCCESS:
-            future.set_result(False)            
+            future.set_result(False)
             return False
-        
+
         self.pending_sub_request[mid] = future
 
         await self.pending_sub_request[mid]