Workflow Engine Kit

Define and execute multi-step agent workflows with conditions, parallel execution, and error handling.

0/6 steps
⚡
Fetch raw data from API
action1200ms expected
pending
❓
Validate data schema
condition200ms expected
pending
⚡
Transform & clean data
action800ms expected
pending
⚡⚡
Run parallel aggregations
parallel1500ms expected
pending
⚡
Generate report
action2000ms expected
pending
⚡
Send notification
action300ms expected
pending

Integration Code

import { createWorkflow, Step } from 'agent-tools-kit/execution'

const workflow = createWorkflow('Data Processing Pipeline')
  .step('fetch', Step.action(async () => fetchData()))
  .step('validate', Step.condition(async (data) => schema.validate(data)))
  .step('transform', Step.action(async (data) => cleanData(data)))
  .step('aggregate', Step.parallel([
    async (data) => aggregateByRegion(data),
    async (data) => aggregateByProduct(data),
    async (data) => aggregateByTime(data),
  ]))
  .step('report', Step.action(async (results) => generateReport(results)))
  .onError('rollback')

const result = await workflow.execute()
// result.steps, result.outputs, result.duration