AsyncConsistency

[zhuofanxu]

Problem Description

Currently, in the agent arun method, there may exist potential synchronous I/O calls, such as those involving database storage for sessions and knowledge bases.
Example:

• agno/libs/agno/agno/agent/agent.py

  Line 988 in d3c321f

  self.read_from_storage()

• agno/libs/agno/agno/agent/agent.py

  Line 2123 in d3c321f

  docs_from_knowledge = self.get_relevant_docs_from_knowledge(query=message_str, **kwargs)

• agno/libs/agno/agno/agent/agent.py

  Line 1244 in d3c321f

  self.write_to_storage()

these potential synchronous blocking I/O calls could render the arun method of the agent meaningless.

Proposed Solution

These synchronous blocking I/O calls need to be implemented asynchronously accordingly.

Alternatives Considered

Additional context

Would you like to work on this?

We welcome contributions! Let us know if you’d like to help implement this feature.
[ ] Yes, I’d love to work on it!
[ ] I’m open to collaborating but need guidance.
[ ] No, I’m just sharing the idea.

[dirkbrnd]

@zhuofanxu this is something we are actively working on. We want to support async on all our internal classes where it makes sense