Sync from GitHub via hub-sync

api/ai-service/app/api/v1/endpoints/route_generation.py

@@ -499,8 +499,8 @@ def generate_routes(payload: RouteGenerateRequest) -> dict[str, Any]:
         raise
     except Exception as exc:
         raise HTTPException(
-            status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
-            detail=f"OSM-CLIP execution failed: {exc}",
+            status_code=status.HTTP_503_SERVICE_UNAVAILABLE,
+            detail="경로 데이터를 불러오지 못했습니다. 잠시 후 다시 시도해 주세요.",
         ) from exc
 
     if not isinstance(result, dict):

router/ai/scripts/clip_osm_region_test.py

@@ -7,7 +7,7 @@ import random
 import threading
 import time
 from pathlib import Path
-from typing import Any
+from typing import Any, Callable
 
 import torch
 import cv2
@@ -143,6 +143,7 @@ LABEL_PROMPTS = {
 }
 
 _CACHE_LOCK = threading.Lock()
+_OVERPASS_SETTINGS_LOCK = threading.Lock()
 _MODEL_CACHE: dict[str, tuple[CLIPModel, CLIPProcessor]] = {}
 _IMAGE_PROTO_CACHE: dict[tuple[str, str, str, tuple[str, ...]], torch.Tensor] = {}
 _TEXT_PROTO_CACHE: dict[tuple[str, str, str, tuple[str, ...]], torch.Tensor] = {}
@@ -155,6 +156,35 @@ _GRAPH_CACHE: dict[tuple[Any, ...], tuple[float, nx.MultiDiGraph, str]] = {}
 GRAPH_CACHE_TTL_SECONDS = 30 * 60
 GRAPH_CACHE_MAX_ENTRIES = 12
 
+# Public Overpass instances occasionally reject requests from a deployment
+# network. OSMnx appends `/interpreter`, so these are API base URLs.
+OVERPASS_API_BASE_URLS = (
+    "https://overpass-api.de/api",
+    "https://overpass.private.coffee/api",
+)
+
+
+def _load_walk_graph_with_overpass_fallback(
+    loader: Callable[[], nx.MultiDiGraph],
+) -> nx.MultiDiGraph:
+    """Load an OSM graph with a deterministic secondary Overpass endpoint."""
+    errors: list[str] = []
+    # osmnx.settings is process-global, therefore changing the endpoint must
+    # not overlap another request handled by the AI service.
+    with _OVERPASS_SETTINGS_LOCK:
+        original_url = ox.settings.overpass_url
+        try:
+            for base_url in OVERPASS_API_BASE_URLS:
+                try:
+                    ox.settings.overpass_url = base_url
+                    return loader()
+                except Exception as exc:
+                    errors.append(f"{base_url}: {exc}")
+        finally:
+            ox.settings.overpass_url = original_url
+
+    raise RuntimeError("All Overpass endpoints failed. " + " | ".join(errors))
+
 
 def _normalize_place_for_cache(place: str) -> str:
     return " ".join(place.strip().lower().split())
@@ -218,11 +248,13 @@ def _build_or_get_walk_graph(
         if cached is not None:
             return cached
 
-        graph = ox.graph_from_point(
-            (center_lat, center_lon),
-            dist=dist_m,
-            network_type="walk",
-            simplify=True,
+        graph = _load_walk_graph_with_overpass_fallback(
+            lambda: ox.graph_from_point(
+                (center_lat, center_lon),
+                dist=dist_m,
+                network_type="walk",
+                simplify=True,
+            )
         )
         location_name = f"{center_lat:.6f},{center_lon:.6f}"
         _set_cached_graph(cache_key, graph, location_name)
@@ -279,16 +311,24 @@ def _build_or_get_walk_graph(
                 geocode_errors.append(f"{query}: {exc}")
 
         if lat_lon is not None:
-            graph = ox.graph_from_point(
-                lat_lon,
-                dist=dist_m,
-                network_type="walk",
-                simplify=True,
+            graph = _load_walk_graph_with_overpass_fallback(
+                lambda: ox.graph_from_point(
+                    lat_lon,
+                    dist=dist_m,
+                    network_type="walk",
+                    simplify=True,
+                )
             )
             location_name = place
         else:
             try:
-                graph = ox.graph_from_place(place, network_type="walk", simplify=True)
+                graph = _load_walk_graph_with_overpass_fallback(
+                    lambda: ox.graph_from_place(
+                        place,
+                        network_type="walk",
+                        simplify=True,
+                    )
+                )
                 location_name = place
             except Exception as exc:
                 detail = " | ".join(geocode_errors + [f"graph_from_place: {exc}"])