pepperplus/pepperplus-cb
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

The Big One #43

Merged
k.marinus merged 93 commits from feat/reset-experiment-and-phase into dev 2026-01-26 19:20:45 +00:00
Conversation 68 Commits 93 Files Changed 64 +10 -3
1 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 5a61225c6f - Show all commits

13
src/control_backend/agents/bdi/bdi_program_manager.py
View File

@@ -175,13 +175,19 @@ class BDIProgramManager(BaseAgent):
""" """
message = InternalMessage( message = InternalMessage(
to=settings.agent_settings.llm_name, to=settings.agent_settings.llm_name,
sender=self.name,
body="clear_history", body="clear_history",
threads="clear history message",
) )
await self.send(message) await self.send(message)
self.logger.debug("Sent message to LLM agent to clear history.") 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): async def _receive_programs(self):
""" """
Continuous loop that receives program updates from the HTTP endpoint. Continuous loop that receives program updates from the HTTP endpoint.
@@ -201,11 +207,12 @@ class BDIProgramManager(BaseAgent):
self._initialize_internal_state(program) self._initialize_internal_state(program)
await self._send_clear_llm_history()
await asyncio.gather( await asyncio.gather(
self._create_agentspeak_and_send_to_bdi(program), self._create_agentspeak_and_send_to_bdi(program),
self._send_beliefs_to_semantic_belief_extractor(), self._send_beliefs_to_semantic_belief_extractor(),
self._send_goals_to_semantic_belief_extractor(), self._send_goals_to_semantic_belief_extractor(),
self._send_clear_llm_history(),
) )
async def setup(self): async def setup(self):