AutomationFlowsAI & RAG › Pipeline 2 — Onboarding → Agent Modification V2

Pipeline 2 — Onboarding → Agent Modification V2

Pipeline 2 — Onboarding → Agent Modification v2. Uses executeCommand, readBinaryFile. Event-driven trigger; 7 nodes.

Event trigger★★★★☆ complexity7 nodesExecute CommandRead Binary File
AI & RAG Trigger: Event Nodes: 7 Complexity: ★★★★☆ Added:

The workflow JSON

Copy or download the full n8n JSON below. Paste it into a new n8n workflow, add your credentials, activate. Full import guide →

Download .json
{
  "name": "Pipeline 2 \u2014 Onboarding \u2192 Agent Modification v2",
  "nodes": [
    {
      "parameters": {},
      "id": "a2b2c3d4-0001-0001-0001-000000000001",
      "name": "Manual Trigger",
      "type": "n8n-nodes-base.manualTrigger",
      "typeVersion": 1,
      "position": [
        240,
        300
      ]
    },
    {
      "parameters": {
        "values": {
          "string": [
            {
              "name": "file_path",
              "value": "transcripts/onboarding_1.txt"
            }
          ]
        },
        "options": {}
      },
      "id": "a2b2c3d4-0002-0002-0002-000000000002",
      "name": "Set File Path",
      "type": "n8n-nodes-base.set",
      "typeVersion": 1,
      "position": [
        460,
        300
      ],
      "notes": "Change file_path to the target onboarding transcript."
    },
    {
      "parameters": {
        "command": "cd /data && python src/pipeline_v2.py --file {{ $json.file_path }} 2>&1",
        "executeOnce": true
      },
      "id": "a2b2c3d4-0003-0003-0003-000000000003",
      "name": "Run Pipeline 2",
      "type": "n8n-nodes-base.executeCommand",
      "typeVersion": 1,
      "position": [
        680,
        300
      ],
      "notes": "Requires ZenTrades project mounted at /data inside n8n."
    },
    {
      "parameters": {
        "conditions": {
          "string": [
            {
              "value1": "={{ $json.exitCode }}",
              "operation": "equal",
              "value2": "0"
            }
          ]
        }
      },
      "id": "a2b2c3d4-0004-0004-0004-000000000004",
      "name": "Check Exit Code",
      "type": "n8n-nodes-base.if",
      "typeVersion": 1,
      "position": [
        900,
        300
      ]
    },
    {
      "parameters": {
        "filePath": "={{ '/data/outputs/accounts/' + $node['Set File Path'].json.file_path.replace('transcripts/','').replace('.txt','').replace('onboarding_', 'demo_') + '/v2/processing_log.json' }}",
        "options": {}
      },
      "id": "a2b2c3d4-0005-0005-0005-000000000005",
      "name": "Read Processing Log v2",
      "type": "n8n-nodes-base.readBinaryFile",
      "typeVersion": 1,
      "position": [
        1120,
        200
      ]
    },
    {
      "parameters": {
        "values": {
          "string": [
            {
              "name": "result",
              "value": "SUCCESS"
            },
            {
              "name": "stdout",
              "value": "={{ $json.stdout }}"
            }
          ]
        }
      },
      "id": "a2b2c3d4-0006-0006-0006-000000000006",
      "name": "Success Response",
      "type": "n8n-nodes-base.set",
      "typeVersion": 1,
      "position": [
        1340,
        200
      ]
    },
    {
      "parameters": {
        "values": {
          "string": [
            {
              "name": "result",
              "value": "FAILED"
            },
            {
              "name": "stderr",
              "value": "={{ $json.stderr }}"
            }
          ]
        }
      },
      "id": "a2b2c3d4-0007-0007-0007-000000000007",
      "name": "Failure Response",
      "type": "n8n-nodes-base.set",
      "typeVersion": 1,
      "position": [
        1120,
        420
      ]
    }
  ],
  "connections": {
    "Manual Trigger": {
      "main": [
        [
          {
            "node": "Set File Path",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Set File Path": {
      "main": [
        [
          {
            "node": "Run Pipeline 2",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Run Pipeline 2": {
      "main": [
        [
          {
            "node": "Check Exit Code",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Check Exit Code": {
      "main": [
        [
          {
            "node": "Read Processing Log v2",
            "type": "main",
            "index": 0
          }
        ],
        [
          {
            "node": "Failure Response",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Read Processing Log v2": {
      "main": [
        [
          {
            "node": "Success Response",
            "type": "main",
            "index": 0
          }
        ]
      ]
    }
  },
  "settings": {
    "executionOrder": "v1"
  }
}
Pro

For the full experience including quality scoring and batch install features for each workflow upgrade to Pro

About this workflow

Pipeline 2 — Onboarding → Agent Modification v2. Uses executeCommand, readBinaryFile. Event-driven trigger; 7 nodes.

Source: https://github.com/pranjalkhare2004/Clara_AI/blob/6ccc333d1ac81d5c85cdbde2c21e676950a34355/workflows/pipeline2_workflow.json — original creator credit. Request a take-down →

More AI & RAG workflows → · Browse all categories →

Related workflows

Workflows that share integrations, category, or trigger type with this one. All free to copy and import.

AI & RAG

Clara Pipeline A - Demo to Agent v1. Uses executeCommand, readBinaryFile. Event-driven trigger; 7 nodes.

Execute Command, Read Binary File
AI & RAG

This workflow creates a multi-talented AI assistant named Simran that interacts with users via Telegram. It can handle text and voice messages, understand the user's intent, and perform various tasks.

MongoDB, Chain Llm, Google Gemini Chat +11
AI & RAG

Estimate material price and total cost for grouped BIM/CAD elements using an LLM-driven analysis. The workflow accepts an existing XLSX (from your model) or, if missing, can trigger a local RvtExporte

OpenAI, Agent, Anthropic Chat +6
AI & RAG

Estimate embodied carbon (CO2e) for grouped BIM/CAD elements. The workflow accepts an existing XLSX (grouped element data) or, if missing, can trigger a local RvtExporter.exe to generate one. It detec

OpenAI, Agent, Anthropic Chat +6
AI & RAG

Clara Pipeline B - Onboarding to Agent v2. Uses executeCommand, readBinaryFile. Event-driven trigger; 6 nodes.

Execute Command, Read Binary File