Run Apache Airflow DAG and retrieve XCom value
Ready for 3.0Ready for 3.0. This template uses no nodes that n8n 3.0 removes. No removed nodes, versions or helpers found. Static check, last run 2026-10-19.
What this workflow does
This workflow has 12 nodes and runs when another workflow calls it. It uses only n8n's built-in nodes.
How it runs
Trigger: When another workflow calls it.
- airflow-api (Edit Fields (Set)): sets 1 field: prefix
- Airflow: dag_run (HTTP Request): calls an HTTP API (POST)
- If: checks a condition and branches into true / false
- Wait: pauses before continuing
- dag run fail (Stop and Error): stops the run with an error
- Airflow: dag_run - state (HTTP Request): calls an HTTP API
- Switch: routes items into 4 branches
- Airflow: dag_run - get result (HTTP Request): calls an HTTP API
- count (Code): runs custom JavaScript code
- If: checks a condition and branches into true / false
…plus 1 more step. See the full node list below.
Before you upgrade to n8n 3.0
Nothing in this workflow is removed in n8n 3.0, so it should import and run after the upgrade.
Nodes used (8)
- HTTP Request
n8n-nodes-base.httpRequest - Code
n8n-nodes-base.code - Stop and Error
n8n-nodes-base.stopAndError - If
n8n-nodes-base.if - Switch
n8n-nodes-base.switch - Execute Workflow Trigger
n8n-nodes-base.executeWorkflowTrigger - Wait
n8n-nodes-base.wait - Edit Fields (Set)
n8n-nodes-base.set
From the author
Run Apache Airflow DAG and Retrieve XCom Value What this workflow does This workflow integrates the Apache Airflow API DAGRun and XCom. It enables n8n to trigger Airflow DAGs and retrieve the execution results. Preparation: 1. Update Airflow API Link Prefix -…