FlowForge is a TypeScript-native workflow engine for building, executing, and monitoring workflows entirely in code. Define type-safe nodes with Zod schemas, compose them into DAG-based workflows, and run them with built-in retry, timeout, checkpointing, and observability.
Type-Safe by Design -- Every node defines its input, output, and config schemas with Zod. Validated at runtime, inferred at compile time.
80+ Built-in Nodes -- Data, AI, communication, control flow, transforms, and agentic tools.
38+ Integrations -- Backed by Composio (MIT, self-hostable).
9 Agentic Tools -- Filesystem, shell, code interpreter, web search, web scrape, git, browser, document parser, math -- all with built-in safety controls.
AI-Native Agent System -- Agent loop with tool calling, MCP client, any node becomes a tool via nodeAsAgentTool().
Human-in-the-Loop -- Approval gates with checkpoint recovery, auto-approve for dev, auto-reject for CI.
Production-Ready -- BullMQ worker, Hono HTTP API, Drizzle/Postgres, OpenTelemetry, cron, circuit breakers.
| Package | Description |
|---|---|
@flowforgejs/sdk |
Workflow DSL -- defineNode(), defineAgentNode(), workflow() builder |
@flowforgejs/engine |
Execution engine with DAG scheduling, retry, event bus, AI provider |
@flowforgejs/nodes |
80+ built-in nodes |
@flowforgejs/shared |
Shared types, errors, schemas |
@flowforgejs/cli |
Developer CLI |
@flowforgejs/worker |
BullMQ worker with Hono HTTP API |
@flowforgejs/dashboard |
Monitoring API |
@flowforgejs/integrations |
Composio-backed integration service |
@flowforgejs/test-utils |
Testing utilities |