pub fn compile_flow( catalog: &Catalog, routines: &Routines, txn: &mut AdminTransaction, plan: QueryPlan, sink: Option<&View>, flow_id: FlowId, ) -> Result<FlowDag>