Skip to content

Conversation

@wangchunf
Copy link
Collaborator

No description provided.

headers['parent_group_id'] = input_message.group_id
return headers

async def send_remote_response_output(self, remote_response: TaskResponse, context: Context,
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

reuse llm_agent and micro refactor

logger.error(f"Error in thread monitor: {e}")

# check and clean up resources for dead threads every 5 seconds
time.sleep(5)
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggest configuring the sleep time

logger.error(f"get agent card failed, agent_id: {self.agent_id}")
raise ValueError(f"get agent card failed, agent_id: {self.agent_id}")
return agent_card.description
desc = sync_exec(remote_agent_desc, self)
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggest call in init and caching it, async refresh avoids information changes after remote restart

@rainsonGain rainsonGain merged commit 5f88fe6 into main Nov 21, 2025
1 check passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants