Fix: orchestrator callback mismatch

backend/main.py

@@ -55,18 +55,18 @@ app.add_middleware(
 async def _run_search(search_id: str, request: TripSearchRequest) -> None:
     """Run the trip search and feed progress into the per-search queue."""
     queue: asyncio.Queue = searches[search_id]["queue"]
+
+    def progress_callback(p: SearchProgress) -> None:
+        queue.put_nowait(p)
+
     try:
-        async for progress in run_trip_search(request):
-            await queue.put(progress)
-            if isinstance(progress, SearchProgress) and progress.step == "done":
-                break
+        results = await run_trip_search(request, progress_callback)
+        searches[search_id]["results"] = results
+        # Push the results list directly so the SSE handler emits the "results" event
+        await queue.put(results)
     except Exception as exc:
         logger.exception("Error in background trip search %s", search_id)
-        # Push an error sentinel so the SSE stream can close cleanly
-        error_progress = SearchProgress(
-            step="error", message=str(exc), progress=0
-        )
-        await queue.put(error_progress)
+        await queue.put(SearchProgress(step="error", message=str(exc), progress=0))
         searches[search_id]["status"] = "error"
         return