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 →
{
"name": "Clara Pipeline - v1 (Demo) + v2 (Onboarding)",
"nodes": [
{
"parameters": {
"httpMethod": "POST",
"path": "v1",
"responseMode": "lastNode",
"options": {}
},
"id": "webhook-v1",
"name": "Webhook /v1",
"type": "n8n-nodes-base.webhook",
"position": [
100,
300
],
"typeVersion": 1
},
{
"parameters": {
"jsCode": "const body = $input.item.json.body;\n\nif (!body.account_id || !body.company) {\n return [{ json: { ok: false, error: 'account_id and company are required' } }];\n}\n\nconst inputPath = body.transcript_path || (body.company + '/transcripts/demo/transcript.txt');\nconst ext = inputPath.split('.').pop().toLowerCase();\n\nconst audioExts = ['mp3','wav','m4a','ogg','flac','webm','aac','wma','mp4','mpeg','mpga'];\nconst validExts = ['txt', ...audioExts];\n\nif (!validExts.includes(ext)) {\n return [{ json: {\n ok: false,\n error: 'Unsupported file format: .' + ext + '. Supported: .txt, .' + audioExts.join(', .'),\n hint: 'Provide a .txt transcript or a Whisper-compatible audio file'\n }}];\n}\n\nreturn [{ json: {\n valid: true,\n account_id: body.account_id,\n company: body.company,\n transcript_path: body.transcript_path || null,\n input_type: ext === 'txt' ? 'transcript' : 'audio',\n ext: ext\n}}];"
},
"id": "validate-v1",
"name": "Validate v1 Input",
"type": "n8n-nodes-base.code",
"position": [
350,
300
],
"typeVersion": 2
},
{
"parameters": {
"conditions": {
"options": {
"caseSensitive": false,
"leftValue": "",
"typeValidation": "loose"
},
"conditions": [
{
"id": "valid-v1-check",
"leftValue": "={{ $json.valid }}",
"rightValue": true,
"operator": {
"type": "boolean",
"operation": "true"
}
}
],
"combinator": "and"
}
},
"id": "if-v1-valid",
"name": "v1 Valid?",
"type": "n8n-nodes-base.if",
"position": [
580,
300
],
"typeVersion": 2
},
{
"parameters": {
"method": "POST",
"url": "http://clara:3000/run",
"sendBody": true,
"specifyBody": "json",
"jsonBody": "={{ JSON.stringify({ account_id: $('Validate v1 Input').item.json.account_id, company: $('Validate v1 Input').item.json.company, transcript_path: $('Validate v1 Input').item.json.transcript_path }) }}",
"options": {
"timeout": 300000
}
},
"id": "run-pipeline-a",
"name": "POST /run (v1)",
"type": "n8n-nodes-base.httpRequest",
"position": [
830,
200
],
"typeVersion": 4,
"retryOnFail": true,
"maxTries": 2,
"waitBetweenTries": 5000
},
{
"parameters": {
"jsCode": "const result = $input.item.json;\nconst ctx = $('Validate v1 Input').item.json;\n\nif (!result.ok) {\n return [{ json: {\n ok: false,\n error: 'Pipeline A failed',\n account_id: ctx.account_id,\n company: ctx.company,\n details: result.error || result\n }}];\n}\n\nconst memo = result.files?.memo || {};\nconst spec = result.files?.agentDraftSpec || {};\n\nreturn [{ json: {\n ok: true,\n pipeline: 'A (demo -> v1)',\n account_id: ctx.account_id,\n company: ctx.company,\n version: result.version || 'v1',\n summary: {\n company_name: memo.company_name || ctx.company,\n industry: memo.industry_type || 'unknown',\n services_count: (memo.services_supported || []).length,\n business_hours: memo.business_hours || {},\n office_address: memo.office_address || null,\n emergency_contacts: (memo.emergency_routing_rules?.contacts || []).length,\n agent_name: spec.agent_name || 'unnamed',\n agent_id: spec.agent_id || null,\n llm_id: spec.llm_id || null,\n unknowns: memo.questions_or_unknowns || []\n }\n}}];"
},
"id": "summary-v1",
"name": "v1 Summary",
"type": "n8n-nodes-base.code",
"position": [
1080,
200
],
"typeVersion": 2
},
{
"parameters": {
"respondWith": "json",
"responseBody": "={{ JSON.stringify($json, null, 2) }}"
},
"id": "respond-v1-ok",
"name": "Respond v1 OK",
"type": "n8n-nodes-base.respondToWebhook",
"position": [
1330,
200
],
"typeVersion": 1
},
{
"parameters": {
"respondWith": "json",
"responseBody": "={{ JSON.stringify($json, null, 2) }}"
},
"id": "respond-v1-err",
"name": "Respond v1 Error",
"type": "n8n-nodes-base.respondToWebhook",
"position": [
830,
420
],
"typeVersion": 1
},
{
"parameters": {
"httpMethod": "POST",
"path": "v2",
"responseMode": "lastNode",
"options": {}
},
"id": "webhook-v2",
"name": "Webhook /v2",
"type": "n8n-nodes-base.webhook",
"position": [
100,
750
],
"typeVersion": 1
},
{
"parameters": {
"jsCode": "const body = $input.item.json.body;\n\nif (!body.account_id || !body.company) {\n return [{ json: { ok: false, error: 'account_id and company are required' } }];\n}\n\nconst audioExts = ['mp3','wav','m4a','ogg','flac','webm','aac','wma','mp4','mpeg','mpga'];\nconst validExts = ['txt', ...audioExts];\n\nconst hasPath = !!body.onboarding_path;\nconst hasTranscript = !!body.transcript;\nconst hasForm = !!(body.form_data && typeof body.form_data === 'object' && Object.keys(body.form_data).length > 0);\nconst hasAny = hasPath || hasTranscript || hasForm;\n\nif (!hasAny) {\n return [{ json: {\n ok: false,\n error: 'No input provided. Send at least one of: onboarding_path, transcript, or form_data'\n }}];\n}\n\nif (hasPath) {\n const ext = body.onboarding_path.split('.').pop().toLowerCase();\n if (!validExts.includes(ext)) {\n return [{ json: {\n ok: false,\n error: 'Unsupported file format: .' + ext + '. Supported: .txt, .' + audioExts.join(', .'),\n hint: 'Provide a .txt transcript or a Whisper-compatible audio file'\n }}];\n }\n}\n\nreturn [{ json: {\n valid: true,\n account_id: body.account_id,\n company: body.company,\n onboarding_path: body.onboarding_path || null,\n transcript: body.transcript || null,\n form_data: body.form_data || null,\n has_transcript_input: hasPath || hasTranscript,\n has_form: hasForm,\n input_summary: [\n hasPath ? ('path: ' + body.onboarding_path) : null,\n hasTranscript ? 'inline transcript' : null,\n hasForm ? ('form (' + Object.keys(body.form_data).length + ' fields)') : null\n ].filter(Boolean).join(' + ')\n}}];"
},
"id": "validate-v2",
"name": "Validate v2 Input",
"type": "n8n-nodes-base.code",
"position": [
350,
750
],
"typeVersion": 2
},
{
"parameters": {
"conditions": {
"options": {
"caseSensitive": false,
"leftValue": "",
"typeValidation": "loose"
},
"conditions": [
{
"id": "valid-v2-check",
"leftValue": "={{ $json.valid }}",
"rightValue": true,
"operator": {
"type": "boolean",
"operation": "true"
}
}
],
"combinator": "and"
}
},
"id": "if-v2-valid",
"name": "v2 Valid?",
"type": "n8n-nodes-base.if",
"position": [
600,
750
],
"typeVersion": 2
},
{
"parameters": {
"method": "POST",
"url": "http://clara:3000/onboard",
"sendBody": true,
"specifyBody": "json",
"jsonBody": "={{ JSON.stringify({ account_id: $('Validate v2 Input').item.json.account_id, company: $('Validate v2 Input').item.json.company, onboarding_path: $('Validate v2 Input').item.json.onboarding_path, transcript: $('Validate v2 Input').item.json.transcript, form_data: $('Validate v2 Input').item.json.form_data }) }}",
"options": {
"timeout": 300000
}
},
"id": "run-pipeline-b",
"name": "POST /onboard (v2)",
"type": "n8n-nodes-base.httpRequest",
"position": [
870,
650
],
"typeVersion": 4,
"retryOnFail": true,
"maxTries": 2,
"waitBetweenTries": 5000
},
{
"parameters": {
"jsCode": "const result = $input.item.json;\nconst ctx = $('Validate v2 Input').item.json;\n\nif (!result.ok) {\n return [{ json: {\n ok: false,\n error: 'Pipeline B failed',\n account_id: ctx.account_id,\n company: ctx.company,\n input_summary: ctx.input_summary,\n details: result.error || result\n }}];\n}\n\nconst memo = result.files?.memo || {};\nconst spec = result.files?.agentDraftSpec || {};\nconst changes = result.files?.changes || {};\n\nreturn [{ json: {\n ok: true,\n pipeline: 'B (onboarding -> v2)',\n account_id: ctx.account_id,\n company: ctx.company,\n version: result.version || 'v2',\n input_summary: ctx.input_summary,\n form_applied: result.form_applied || false,\n summary: {\n company_name: memo.company_name || ctx.company,\n total_changes: changes.total_changes || (changes.changes || []).length,\n source: changes.source || 'unknown',\n agent_name: spec.agent_name || 'unnamed',\n agent_id: spec.agent_id || null,\n llm_id: spec.llm_id || null,\n unknowns_remaining: memo.questions_or_unknowns || []\n }\n}}];"
},
"id": "summary-v2",
"name": "v2 Summary",
"type": "n8n-nodes-base.code",
"position": [
1120,
650
],
"typeVersion": 2
},
{
"parameters": {
"respondWith": "json",
"responseBody": "={{ JSON.stringify($json, null, 2) }}"
},
"id": "respond-v2-ok",
"name": "Respond v2 OK",
"type": "n8n-nodes-base.respondToWebhook",
"position": [
1370,
650
],
"typeVersion": 1
},
{
"parameters": {
"respondWith": "json",
"responseBody": "={{ JSON.stringify($json, null, 2) }}"
},
"id": "respond-v2-err",
"name": "Respond v2 Error",
"type": "n8n-nodes-base.respondToWebhook",
"position": [
870,
870
],
"typeVersion": 1
}
],
"connections": {
"Webhook /v1": {
"main": [
[
{
"node": "Validate v1 Input",
"type": "main",
"index": 0
}
]
]
},
"Validate v1 Input": {
"main": [
[
{
"node": "v1 Valid?",
"type": "main",
"index": 0
}
]
]
},
"v1 Valid?": {
"main": [
[
{
"node": "POST /run (v1)",
"type": "main",
"index": 0
}
],
[
{
"node": "Respond v1 Error",
"type": "main",
"index": 0
}
]
]
},
"POST /run (v1)": {
"main": [
[
{
"node": "v1 Summary",
"type": "main",
"index": 0
}
]
]
},
"v1 Summary": {
"main": [
[
{
"node": "Respond v1 OK",
"type": "main",
"index": 0
}
]
]
},
"Webhook /v2": {
"main": [
[
{
"node": "Validate v2 Input",
"type": "main",
"index": 0
}
]
]
},
"Validate v2 Input": {
"main": [
[
{
"node": "v2 Valid?",
"type": "main",
"index": 0
}
]
]
},
"v2 Valid?": {
"main": [
[
{
"node": "POST /onboard (v2)",
"type": "main",
"index": 0
}
],
[
{
"node": "Respond v2 Error",
"type": "main",
"index": 0
}
]
]
},
"POST /onboard (v2)": {
"main": [
[
{
"node": "v2 Summary",
"type": "main",
"index": 0
}
]
]
},
"v2 Summary": {
"main": [
[
{
"node": "Respond v2 OK",
"type": "main",
"index": 0
}
]
]
}
}
}
Pro
For the full experience including quality scoring and batch install features for each workflow upgrade to Pro
About this workflow
Clara Pipeline - v1 (Demo) + v2 (Onboarding). Uses httpRequest. Webhook trigger; 14 nodes.
Source: https://github.com/subhamagarrwal/ZenTrades_assignment/blob/c8e808a4cda9f477787fadeb3be31119cfcb58b1/workflows/pipeline_full.json — original creator credit. Request a take-down →
Related workflows
Workflows that share integrations, category, or trigger type with this one. All free to copy and import.
This n8n template provides enterprise-level version control for your workflows using GitHub integration. Stop losing hours to broken workflows and manual exports – get proper commit history, visual di
n8n, Execute Workflow Trigger, HTTP Request +1
This flow creates dummy files for every item added in your *Arrs (Radarr/Sonarr) with the tag .
HTTP Request, Ssh
eek-Go v2 (Batch-Then-Review). Uses httpRequest. Webhook trigger; 75 nodes.
HTTP Request
This workflow receives webhook requests from a content calendar and uses the X API v2 to publish text posts, threads, image/video posts, and polls, as well as delete existing posts and run a credentia
HTTP Request
This workflow acts as a central API gateway for all technical indicator agents in the Binance Spot Market Quant AI system. It listens for incoming webhook requests and dynamically routes them to the c
HTTP Request