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