Update api/endpoints/location.py

api/endpoints/location.py

@@ -28,13 +28,19 @@ async def get_coordinates_v1(cord):
         return None
 
 async def process_coordinates(supabase_user_data, max_concurrency=15):
-    semaphore = asyncio.Semaphore(max_concurrency)
+    coords=[]
+    with concurrent.futures.ThreadPoolExecutor(max_workers=max_workers) as executor:
+        futures = {executor.submit(LocationService.get_coordinates,cord): cord for cord in supabase_user_data}
+        for future in concurrent.futures.as_completed(futures):
+            task_name = futures[future]
+            try:
+                result = future.result()
+                coords.append(result)
+                print(f"{task_name} completed with result: {result}")
+            except Exception as exc:
+                print(f"{task_name} generated an exception: {exc}")
 
-    async def bounded_get_coordinates(cord):
-        async with semaphore:
-            return await get_coordinates_v1(cord)
-
-    coords = await asyncio.gather(*[bounded_get_coordinates(cord) for cord in supabase_user_data])
+    # coords = await asyncio.gather(*[bounded_get_coordinates(cord) for cord in supabase_user_data])
     return [coord for coord in coords if coord is not None]
 
 @router.post("/get_coordinates")