diff --git a/src/control_backend/agents/bdi/bdi_program_manager.py b/src/control_backend/agents/bdi/bdi_program_manager.py index 1ee3e3c..8b8c68f 100644 --- a/src/control_backend/agents/bdi/bdi_program_manager.py +++ b/src/control_backend/agents/bdi/bdi_program_manager.py @@ -175,13 +175,19 @@ class BDIProgramManager(BaseAgent): """ message = InternalMessage( to=settings.agent_settings.llm_name, - sender=self.name, body="clear_history", - threads="clear history message", ) await self.send(message) self.logger.debug("Sent message to LLM agent to clear history.") + extractor_msg = InternalMessage( + to=settings.agent_settings.text_belief_extractor_name, + thread="conversation_history", + body="reset", + ) + await self.send(extractor_msg) + self.logger.debug("Sent message to extractor agent to clear history.") + async def _receive_programs(self): """ Continuous loop that receives program updates from the HTTP endpoint. @@ -201,11 +207,12 @@ class BDIProgramManager(BaseAgent): self._initialize_internal_state(program) + await self._send_clear_llm_history() + await asyncio.gather( self._create_agentspeak_and_send_to_bdi(program), self._send_beliefs_to_semantic_belief_extractor(), self._send_goals_to_semantic_belief_extractor(), - self._send_clear_llm_history(), ) async def setup(self):