agent_controller: in PAUSED state reduce delegate logspam from delegate (#3946)

This commit is contained in:
tobitege 2024-09-19 14:34:38 +02:00 committed by GitHub
parent 31dbd3d02e
commit 620526b8b4
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 6 additions and 3 deletions

View File

@ -57,7 +57,7 @@ class Flags:
@classmethod
def from_dict(self, flags_dict):
"""Helper for JSON serializble requirement."""
"""Helper for JSON serializable requirement."""
if isinstance(flags_dict, Flags):
return flags_dict

View File

@ -383,7 +383,10 @@ class AgentController:
if self.delegate is not None:
assert self.delegate != self
await self._delegate_step()
if self.delegate.get_agent_state() == AgentState.PAUSED:
await asyncio.sleep(1)
else:
await self._delegate_step()
return
logger.info(
@ -458,7 +461,7 @@ class AgentController:
self.delegate = None
self.delegateAction = None
await self.report_error('Delegator agent encounters an error')
await self.report_error('Delegator agent encountered an error')
elif delegate_state in (AgentState.FINISHED, AgentState.REJECTED):
logger.info(
f'[Agent Controller {self.id}] Delegate agent has finished execution'