workflow-engine

name	workflow-engine
description	DAG-based workflow execution engine with parallel steps, retries, and conditional branching

Skill: SuperClaude Workflow Engine

Purpose

DAG-based workflow execution engine (agents/workflow_engine.py) with topological ordering, cycle detection, and dependency resolution.

Usage

from agents.workflow_engine import WorkflowEngine, Workflow, Task

engine = WorkflowEngine()
wf = Workflow(workflow_id="deploy", name="Deploy Pipeline")
wf.add_task(Task(task_id="build", name="Build", action=lambda: "built"))
wf.add_task(Task(task_id="test", name="Test", action=lambda: "tested", depends_on=["build"]))
engine.register(wf)
results = engine.execute("deploy")

Key Classes

• Task — single DAG node with action, dependencies, status, retries
• Workflow — named collection of tasks, DAG validation, ready-task detection
• WorkflowEngine — registry, topological execution

Testing

python -m pytest tests/test_workflow_engine.py -v

Related Issues

• Issue #235: SuperClaude Workflow Engine