ironflow-engine

Workflow orchestration engine for ironflow.

Workflows are defined as Rust-native handlers implementing WorkflowHandler. Handlers receive a WorkflowContext and can chain step outputs, use native if/else/match for conditional branching, and execute steps in parallel.

Handlers can be executed inline or enqueued for a background worker.

Custom operations

Implement Operation to define custom step types (e.g. GitLab, Gmail, Slack) that integrate into the workflow lifecycle. Call WorkflowContext::operation() inside a handler to execute them with full step tracking.

Example

use ironflow_engine::prelude::*;
use std::future::Future;
use std::pin::Pin;

struct DeployWorkflow;

impl WorkflowHandler for DeployWorkflow {
    fn name(&self) -> &str { "deploy" }
    fn execute<'a>(&'a self, ctx: &'a mut WorkflowContext) -> HandlerFuture<'a> {
        Box::pin(async move {
            let build = ctx.shell("build", ShellConfig::new("cargo build")).await?;
            ctx.agent("review", AgentStepConfig::new(
                &format!("Review: {}", build.output["stdout"])
            )).await?;
            Ok(())
        })
    }
}