Function compile_flow 

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