debug mqtt

app.py

@@ -38,7 +38,7 @@ def main():
 
 
 @app.post("/send-coordinates")
-def receive_coordinates(payload: CoordinatesPayload,background_tasks: BackgroundTasks):
+async def receive_coordinates(payload: CoordinatesPayload,background_tasks: BackgroundTasks):
     coords= payload.coords
     state_= payload.state
     duration= payload.duration
@@ -50,10 +50,11 @@ def receive_coordinates(payload: CoordinatesPayload,background_tasks: Background
     traffic_lights = get_traffic_in_container(coords)
     tl_ids = check_signals(traffic_lights)
     if tl_ids:
+        
         for tl_id in tl_ids:
-            background_tasks.add_task(open_signal, tl_id, state_, duration,delay) #"EMR" # "ACC"
-
-        return {"found_signals": tl_ids}
+            #background_tasks.add_task(open_signal, tl_id, state_, duration,delay) #"EMR" # "ACC"
+            answer = await open_signal(tl_id, state_, duration,delay)
+            return {"answer": answer} # temp here 
     else:
         return {"error": "No traffic signals found in database"+str(traffic_lights)}