pub async fn emit_started(task_id: impl Into<String>)
Emit a StreamEvent::TaskStarted on the ambient stream.
StreamEvent::TaskStarted