@@ -986,14 +986,11 @@ async def generate():
986986 new_image_url = response .get ("image_url" )
987987 new_image_prompt = response .get ("image_prompt" )
988988 new_image_revised_prompt = response .get ("image_revised_prompt" )
989- logger .info (f"Regeneration persistence - new image_url: { new_image_url } , "
990- f"new image_prompt present: { bool (new_image_prompt )} , "
991- f"products_data count: { len (products_data ) if products_data else 0 } " )
992989
993990 existing_conversation = await cosmos_service .get_conversation (conversation_id , user_id )
994- existing_content = (existing_conversation or {}).get ("generated_content" , {})
991+ raw_content = (existing_conversation or {}).get ("generated_content" )
992+ existing_content = raw_content if isinstance (raw_content , dict ) else {}
995993 old_image_url = existing_content .get ("image_url" )
996- logger .info (f"Regeneration persistence - old image_url: { old_image_url } " )
997994
998995 updated_content = {
999996 ** existing_content ,
@@ -1002,14 +999,12 @@ async def generate():
1002999 "image_revised_prompt" : new_image_revised_prompt if new_image_revised_prompt else existing_content .get ("image_revised_prompt" ),
10031000 "selected_products" : products_data if products_data else existing_content .get ("selected_products" , []),
10041001 }
1005- logger .info (f"Regeneration persistence - saving image_url: { updated_content .get ('image_url' )} " )
10061002
10071003 await cosmos_service .save_generated_content (
10081004 conversation_id = conversation_id ,
10091005 user_id = user_id ,
10101006 generated_content = updated_content
10111007 )
1012- logger .info (f"Regeneration persistence - save_generated_content completed successfully" )
10131008 except Exception as e :
10141009 logger .warning (f"Failed to save regeneration response to CosmosDB: { e } " )
10151010
0 commit comments