diff --git a/bincio/serve/server.py b/bincio/serve/server.py index 94e7525..e8031ca 100644 --- a/bincio/serve/server.py +++ b/bincio/serve/server.py @@ -1003,9 +1003,9 @@ async def serve_strava_sync_stream(bincio_session: Optional[str] = Cookie(defaul def event_stream(): try: for event in strava_sync_iter(dd, strava_client_id, strava_client_secret, originals_dir): - yield f"data: {json.dumps(event)}\n\n" if event["type"] == "done": - _trigger_rebuild(user.handle) + _trigger_rebuild(user.handle) # start before client closes connection + yield f"data: {json.dumps(event)}\n\n" except Exception as exc: yield f"data: {json.dumps({'type': 'error', 'message': str(exc)})}\n\n"