Overview

Execute a workflow for each item in a list, in parallel. Processes arrays by executing a workflow on each element with configurable concurrency control.

When to Use

Use this node when you need to process arrays or lists in parallel, such as bulk operations on users, processing multiple files, or sending notifications to multiple recipients.

Parameters

• arrayInput (required) - Array of items to process in parallel
  • Examples:
    • {{previousNode.result.items}}
    • [1, 2, 3, 4, 5]
    • {{0.userList}}
• workerId (required) - Workflow to execute on each array element
  • Examples: "user-processor", "data-transformer", "email-sender"
• inputParamName (optional) - Parameter name for passing array element to the workflow
  • Default: "item"
  • Examples: "item", "user", "data"
• concurrency (optional) - Maximum parallel executions (system-limited)
  • Default: 3
  • Examples: 1, 5, 10
• continueOnError (optional) - Whether to continue processing if an item fails
  • Default: false
  • Examples: true, false
• inheritSession (optional) - Whether the workflow inherits parent session context
  • Default: false
• parameterMapping (optional) - Optional mapping to transform array items to the workflow's expected format
  • Examples:
    • { "userId": "item.id", "userName": "item.name" }
    • { "age": { "source": "item", "path": "profile.age" } }

Usage Example

{
    name: "Process User List",
    description: "Repeat Workflow Node - process multiple users in parallel",
    nodeId: "n",
    operationReference: {
        methodId: "map_worker"
    },
    parameters: [
        {
            name: "arrayInput",
            value: "{{previousNode.result.users}}" // Array of users
        },
        {
            name: "workerId",
            value: "user-notification-sender" // Workflow for each user
        },
        { name: "inputParamName", value: "user" }, // Parameter name in workflow
        { name: "concurrency", value: 5 }, // Process 5 users at once
        { name: "continueOnError", value: true } // Skip failed users
    ]
}

Capabilities

• Parallel array element processing
• Configurable concurrency control
• Error handling strategies (fail-fast or continue)
• Progress tracking and execution metrics
• Dynamic parameter passing to workflows

Advanced Features

• Automatic result aggregation with success/error counts
• Item index tracking (__mapItemIndex parameter)
• Memory-efficient processing for large arrays
• Partial success handling with detailed error reporting

Result Access

{{nodeId.results}} - Array of all results {{nodeId.results.0.result}} - First item result {{nodeId.successCount}} - Number of successful executions {{nodeId.errorCount}} - Number of failed executions