pub fn build_graph( plan_node: PlanRef, job_type: Option<GraphJobType>, ) -> Result<StreamFragmentGraph, RwError>