diff --git a/sgr_agent_core/agents/dialog_agent.py b/sgr_agent_core/agents/dialog_agent.py index b843863a..04f6998b 100644 --- a/sgr_agent_core/agents/dialog_agent.py +++ b/sgr_agent_core/agents/dialog_agent.py @@ -62,7 +62,7 @@ async def _after_action_phase(self, action_tool: BaseTool, result: str) -> None: self.logger.info("\n⏸️ Research paused - please answer questions") self._context.state = AgentStatesEnum.WAITING_FOR_CLARIFICATION self.streaming_generator.finish( - phase_id="{self._context.iteration}-final", content=self._context.execution_result + phase_id=f"{self._context.iteration}-final", content=self._context.execution_result ) self._context.clarification_received.clear() await self._context.clarification_received.wait() @@ -73,7 +73,7 @@ async def _after_action_phase(self, action_tool: BaseTool, result: str) -> None: self.logger.info("\n💬 Dialog shared - agent waiting for response") self._context.state = AgentStatesEnum.WAITING_FOR_CLARIFICATION self.streaming_generator.finish( - phase_id="{self._context.iteration}-final", content=self._context.execution_result + phase_id=f"{self._context.iteration}-final", content=self._context.execution_result ) self._context.clarification_received.clear() await self._context.clarification_received.wait() diff --git a/sgr_agent_core/base_agent.py b/sgr_agent_core/base_agent.py index 6c3f0363..6abd8d9e 100644 --- a/sgr_agent_core/base_agent.py +++ b/sgr_agent_core/base_agent.py @@ -246,7 +246,7 @@ async def _execution_step(self): if isinstance(action_tool, ClarificationTool): self.logger.info("\n⏸️ Research paused - please answer questions") self.streaming_generator.finish( - phase_id="{self._context.iteration}-final", content=self._context.execution_result + phase_id=f"{self._context.iteration}-final", content=self._context.execution_result ) self._context.clarification_received.clear() await self._context.clarification_received.wait()