Skip to main content

analyze_flow

recoco_core::builder::analyzer

Function analyze_flow 

Source 
pub async fn analyze_flow(
    flow_inst: &FlowInstanceSpec,
    flow_ctx: Arc<FlowInstanceContext>,
) -> Result<(FlowSchema, AnalyzedSetupState, impl Future<Output = Result<ExecutionPlan>> + Send + use<>)>