Merge wait_for_n

Wait For N

Fan-in barrier: waits for N upstream branches, merges payloads, fires once.

What does it do?

The meeting point. Waits for several parallel tasks to finish before letting the flow continue.

How does it work?

Placed after splitting the flow (e.g. with a Fan Out). It pauses execution until it receives signals from all required branches, then merges the results into a single bundle.

Why use it?

If you sent the system to check stock and shipping price simultaneously, you need to wait until you have both pieces of data before the AI Agent can compose the full reply.

Inputs

This node takes no structured inputs.

Outputs

name	type
`received`	number
`expected`	number
`ready`	boolean
`branch`	string
`merged`	object

Branches

Fixed branches

ready — Ready

Configuration

expected integer required

memory_key string required default: "__merge_state"

strategy "shallow" | "by_branch" required default: "shallow"

branch_when_ready string required default: "ready"

Default configuration

{
  "expected": 2,
  "memory_key": "__merge_state",
  "strategy": "shallow",
  "branch_when_ready": "ready"
}

Emitted events

This node does not publish events on the pubsub channel.