@@ -423,14 +423,14 @@ async def create_session_with_id(
423
423
)
424
424
is not None
425
425
):
426
- logger .warning ("Session already exists: %s" , session_id )
427
426
raise HTTPException (
428
427
status_code = 400 , detail = f"Session already exists: { session_id } "
429
428
)
430
- logger .info ("New session created: %s" , session_id )
431
- return await self .session_service .create_session (
429
+ session = await self .session_service .create_session (
432
430
app_name = app_name , user_id = user_id , state = state , session_id = session_id
433
431
)
432
+ logger .info ("New session created: %s" , session_id )
433
+ return session
434
434
435
435
@app .post (
436
436
"/apps/{app_name}/users/{user_id}/sessions" ,
@@ -442,7 +442,6 @@ async def create_session(
442
442
state : Optional [dict [str , Any ]] = None ,
443
443
events : Optional [list [Event ]] = None ,
444
444
) -> Session :
445
- logger .info ("New session created" )
446
445
session = await self .session_service .create_session (
447
446
app_name = app_name , user_id = user_id , state = state
448
447
)
@@ -451,6 +450,7 @@ async def create_session(
451
450
for event in events :
452
451
await self .session_service .append_event (session = session , event = event )
453
452
453
+ logger .info ("New session created" )
454
454
return session
455
455
456
456
@app .post (
0 commit comments