What is the Pipeline Builder?

The Pipeline Preflight validates multi-actor data pipelines and generates TypeScript orchestration code. Define pipeline stages with actor IDs and field mappings, and the builder checks that output fields from each stage map correctly to the next stage's input fields.

The builder identifies type mismatches between stages, warns about missing field mappings, and generates complete Actor.call() chain code that you can deploy as a new orchestration actor. It also estimates total pipeline cost by summing PPE prices across all stages.

The generated code shape is yours to pick. Codegen mode controls how production-ready the output is: Minimal emits a plain Actor.call chain, Production-ish wraps each stage in try/catch with log.warning, and Typed adds explicit ApifyCallOptions and satisfies assertions for end-to-end TypeScript safety. Pagination mode picks the dataset-read strategy: Limit 1000 is fast but silently truncates anything past 1K records, while Paginate all iterates until the cursor is exhausted — what you want as soon as a stage emits more than 1K. Tick "Validate runtime" to call the Input Guard on each stage with synthetic input from the mapping; it catches broken fieldMappings before codegen at a per-stage Input Guard charge. By default the builder also emits a top-level agentContract object describing the pipeline for MCP/LLM planners — turn it off in the Options panel if you are integrating with a non-agent runtime.

Pipeline Preflight costs $0.40 per build and does not run any actors — it reads schemas from latest builds. Visit apifyforge.com/tools/pipeline-builder for documentation.

Options

• Pipeline Stages (JSON) — array of stage objects. Each stage requires actorId; downstream stages can declare a fieldMapping mapping their input fields to the previous stage's output fields.
• Codegen mode — Minimal (plain Actor.call chain), Production-ish (try/catch + log.warning per stage), Typed (adds explicit ApifyCallOptions + satisfies assertions).
• Pagination mode — Limit 1000 (fast, silently truncates past 1K records) or Paginate all (generated helper iterates until offset + count ≥ total). Stages emitting >1000 records silently lose data with limit_1000.
• Validate runtime — calls input-tester on each stage with synthetic input from the mapping. Catches broken fieldMappings before codegen. Adds a per-stage input-tester charge.

Options ▸ panel

• Suggestion mode — controls how NO_FIELD_MAPPING issues suggest fix candidates. Schema only (default) or Schema + naming.
• Strictness — Default or Strict (louder advisory surface).
• Emit agent contract — emits a top-level agentContract object for MCP/LLM planners. Default on.