workflows.fit
Back to n8n workflows
n8n templateFreeBy Antonio Cheong

Run Apache Airflow DAG and retrieve XCom value

Run Apache Airflow DAG and Retrieve XCom Value What this workflow does This workflow integrates the Apache Airflow API [DAGRun](https://airflow.apache.org/docs/apache-airflow/2.10.5/stable-rest-api-ref.htmltag/DAGRun)...

DevelopmentCore NodesUtilityHttp RequestCodeStop And ErrorIf
Loading interactive preview...

Template notes

Run Apache Airflow DAG and Retrieve XCom Value

What this workflow does

This workflow integrates the Apache Airflow API [DAGRun](https://airflow.apache.org/docs/apache-airflow/2.10.5/stable-rest-api-ref.htmltag/DAGRun) and [XCom](https://airflow.apache.org/docs/apache-airflow/2.10.5/stable-rest-api-ref.htmltag/XCom). It enables n8n to trigger Airflow DAGs and retrieve the execution results.

Preparation:

1. Update Airflow API Link Prefix

- Navigate to the airflow-api node. - Update the prefix of the Airflow API link in the format: http(s)://ip:port. - Example: https://airflow.example.com

2. Configure Authentication

- Go to the Airflow: dagrun node. - Update the Basic Auth credentials with your Airflow username and password. - Repeat this step for Airflow: dagrun - state and Airflow: dagrun - get result nodes.