|
1
|
from agent import AgentContext |
|
2
|
from helpers.defer import DeferredTask |
|
3
|
from api.message import Message |
|
4
|
|
|
5
|
|
|
6
|
class MessageAsync(Message): |
|
7
|
async def respond(self, task: DeferredTask, context: AgentContext): |
|
8
|
return { |
|
9
|
"message": "Message received.", |
|
10
|
"context": context.id, |
|
11
|
} |