Fix: persist runs by passing asked_question_ids

backend/api/conversation_service.py

@@ -510,7 +510,12 @@ class ConversationService:
             chat_info.status = ConversationStatus.COMPLETED
             await self._send_status_update(conversation_id, ConversationStatus.COMPLETED)
 
-            await self._run_resource_agent(conversation_id)
+            asked_ids = None
+            try:
+                asked_ids = list(getattr(chat_info, "asked_question_ids", None) or [])
+            except Exception:
+                asked_ids = None
+            await self._run_resource_agent(conversation_id, asked_question_ids=asked_ids)
 
             self.active_human_chats.pop(conversation_id, None)
             self.transcripts.pop(conversation_id, None)
@@ -931,7 +936,12 @@ class ConversationService:
 
                 # Trigger resource-agent analysis only for natural completion (not user stop)
                 if not conv_info.stop_requested:
-                    await self._run_resource_agent(conversation_id)
+                    asked_ids = None
+                    try:
+                        asked_ids = list(getattr(manager, "asked_question_ids", None) or [])
+                    except Exception:
+                        asked_ids = None
+                    await self._run_resource_agent(conversation_id, asked_question_ids=asked_ids)
 
                 # End of lifecycle (MVP): remove completed conversation state
                 self.active_conversations.pop(conversation_id, None)
@@ -941,7 +951,7 @@ class ConversationService:
             if conversation_id not in self.active_conversations:
                 self.transcripts.pop(conversation_id, None)
 
-    async def _run_resource_agent(self, conversation_id: str):
+    async def _run_resource_agent(self, conversation_id: str, *, asked_question_ids: Optional[List[str]] = None):
         """Run post-conversation resource agent analysis and broadcast results."""
         transcript = self.transcripts.get(conversation_id, [])
         if not transcript:
@@ -999,7 +1009,7 @@ class ConversationService:
                         "patient_prompt_addition": getattr(conv_info, "patient_prompt_addition", None),
                         "surveyor_attributes": getattr(conv_info, "surveyor_attributes", None),
                         "surveyor_question_bank": getattr(conv_info, "surveyor_question_bank", None),
-                        "asked_question_ids": getattr(manager, "asked_question_ids", None) if hasattr(manager, "asked_question_ids") else None,
+                        "asked_question_ids": asked_question_ids,
                     },
                 }