Skip to main content

execute_pipeline_with_runtime_request_gate

Function execute_pipeline_with_runtime_request_gate 

Source
pub async fn execute_pipeline_with_runtime_request_gate<FStart, FResult, FCancel, FGate>(
    pipeline: &Pipeline,
    selected_base_url_key: Option<&str>,
    specs: Option<&[RuntimeSpec]>,
    env_groups: Option<&[RuntimeEnvGroup]>,
    selected_env_group_slug: Option<&str>,
    on_step_start: FStart,
    on_step_result: FResult,
    should_cancel: FCancel,
    on_request_start: FGate,
) -> Vec<StepExecutionResult>
where FStart: FnMut(&str), FResult: FnMut(&StepExecutionResult), FCancel: FnMut() -> bool, FGate: for<'a> FnMut(&'a StepRequest) -> Pin<Box<dyn Future<Output = bool> + Send + 'a>> + Send,