diff --git a/src/google/adk/cli/adk_web_server.py b/src/google/adk/cli/adk_web_server.py index 724a1298..1886ec47 100644 --- a/src/google/adk/cli/adk_web_server.py +++ b/src/google/adk/cli/adk_web_server.py @@ -423,14 +423,14 @@ class AdkWebServer: ) is not None ): - logger.warning("Session already exists: %s", session_id) raise HTTPException( status_code=400, detail=f"Session already exists: {session_id}" ) - logger.info("New session created: %s", session_id) - return await self.session_service.create_session( + session = await self.session_service.create_session( app_name=app_name, user_id=user_id, state=state, session_id=session_id ) + logger.info("New session created: %s", session_id) + return session @app.post( "/apps/{app_name}/users/{user_id}/sessions", @@ -442,7 +442,6 @@ class AdkWebServer: state: Optional[dict[str, Any]] = None, events: Optional[list[Event]] = None, ) -> Session: - logger.info("New session created") session = await self.session_service.create_session( app_name=app_name, user_id=user_id, state=state ) @@ -451,6 +450,7 @@ class AdkWebServer: for event in events: await self.session_service.append_event(session=session, event=event) + logger.info("New session created") return session @app.post(