agent_zero_framework/python/api/message_async.py

from agent import AgentContext
from python.helpers.defer import DeferredTask
from python.api.message import Message


class MessageAsync(Message):
    async def respond(self, task: DeferredTask, context: AgentContext):
        return {
            "message": "Message received.",
            "context": context.id,
        }