Skip to main content

compile_subscription_flow

reifydb_engine::flow::compiler

Function compile_subscription_flow 

Source 
pub fn compile_subscription_flow(
    catalog: &Catalog,
    txn: &mut AdminTransaction,
    plan: QueryPlan,
    subscription: &SubscriptionDef,
    flow_id: FlowId,
) -> Result<FlowDag>