Function emit_failed 

pub async fn emit_failed(task_id: impl Into<String>, error: impl Into<String>)

Emit a StreamEvent::TaskFailed on the ambient stream.