debug mqtt

traffic_utils.py

@@ -3,6 +3,8 @@ from database_manager import *
 from dotenv import load_dotenv
 import os
 import state
+import asyncio
+
 load_dotenv(dotenv_path="keys.env")
 
 overpass_url = os.getenv("URL_Traffic")
@@ -30,16 +32,21 @@ def get_rectangle_container(coordinates):
     min_lat, max_lat = min(lats), max(lats)
     min_lon, max_lon = min(lons), max(lons)
     return min_lat, max_lat, min_lon, max_lon
-import asyncio
+
+
+async def wait_check_conection(tl_id,check_time):
+    start = time.time()
+    while time.time() - start < check_time:
+        if state.request[tl_id]['State'] != state.status_chk:
+            break
+        await asyncio.sleep(0.2)  
 
 async def open_signal(tl_id,state_,duration,delay):
     check_time = 10
     await asyncio.sleep(delay)
 
     state.request[tl_id]['State'] = state.status_chk
-    
-    check_time = 10
-    await asyncio.sleep(check_time)
+    await wait_check_conection(tl_id,check_time)#asyncio.sleep(check_time)
 
 
     if  (state.request[tl_id]['accepted']== True):