What happened?
start_work in TaskUpdater uses the update_status method, which publishes a TaskStatusUpdateEvent. However, from the 9.3. Streaming Task Execution (SSE) example in the specifications, when a task is started, it should be a Task event, with status being submitted (or working should be ok too?).
|
async def start_work(self, message: Message | None = None) -> None: |
|
"""Marks the task as working and publishes a status update.""" |
|
await self.update_status( |
|
TaskState.working, |
|
message=message, |
|
) |
Relevant log output
N/A
Code of Conduct
What happened?
start_workinTaskUpdateruses theupdate_statusmethod, which publishes aTaskStatusUpdateEvent. However, from the 9.3. Streaming Task Execution (SSE) example in the specifications, when a task is started, it should be aTaskevent, with status beingsubmitted(orworkingshould be ok too?).a2a-python/src/a2a/server/tasks/task_updater.py
Lines 153 to 158 in 1dbe33d
Relevant log output
N/A
Code of Conduct