Function spawn_graph 

pub fn spawn_graph(
    flow_runner: FlowRunner,
    session_id: impl Into<String>,
    buffer: usize,
) -> (StreamReceiver, JoinHandle<Result<ExecutionResult>>)

Drive a FlowRunner to completion, streaming every task’s emit_* calls out.