Spaces:
Running
Running
Update api/endpoints/location.py
Browse files
api/endpoints/location.py
CHANGED
@@ -6,7 +6,7 @@ import core.init_supabase as sp
|
|
6 |
import asyncio
|
7 |
router = APIRouter()
|
8 |
|
9 |
-
async def
|
10 |
try:
|
11 |
return await LocationService.get_coordinates(cord)
|
12 |
except Exception as exc:
|
@@ -18,7 +18,7 @@ async def process_coordinates(supabase_user_data, max_concurrency=15):
|
|
18 |
|
19 |
async def bounded_get_coordinates(cord):
|
20 |
async with semaphore:
|
21 |
-
return await
|
22 |
|
23 |
coords = await asyncio.gather(*[bounded_get_coordinates(cord) for cord in supabase_user_data])
|
24 |
return [coord for coord in coords if coord is not None]
|
|
|
6 |
import asyncio
|
7 |
router = APIRouter()
|
8 |
|
9 |
+
async def get_coordinates_v1(cord):
|
10 |
try:
|
11 |
return await LocationService.get_coordinates(cord)
|
12 |
except Exception as exc:
|
|
|
18 |
|
19 |
async def bounded_get_coordinates(cord):
|
20 |
async with semaphore:
|
21 |
+
return await get_coordinates_v1(cord)
|
22 |
|
23 |
coords = await asyncio.gather(*[bounded_get_coordinates(cord) for cord in supabase_user_data])
|
24 |
return [coord for coord in coords if coord is not None]
|