Community Contributed Airflow Dag Run

Name: Community Contributed Airflow Dag Run
Rating: 4.0 (1 reviews)
Author: Free N8N

Beginner

0 nodes connected

detail.loadingPreview

Free N8N Temples

20 views

0 downloads

Community Contributedairflowapiautomationdag-runmonitoring

This workflow triggers an Airflow DAG run and monitors its state.

🚀Ready to Deploy This Workflow?

⚡Deploy on Zeabur 🎁Get $200 Credit on DigitalOcean

About This Workflow

Overview

This n8n workflow automates the process of triggering an Airflow DAG run, monitoring its status, and handling different outcomes like success, failure, or prolonged waiting periods. It utilizes Airflow API calls to start DAGs and check their execution state. The workflow also includes logic to stop and error out if the DAG run takes too long to complete or fails.

Key Features

Triggers Airflow DAG runs via API.
Monitors the state of the triggered DAG run.
Handles success, failure, and queued states.
Implements a timeout mechanism for DAG runs.
Provides error handling for prolonged or failed DAG runs.

How To Use

Import the workflow into your n8n instance.
Configure the Airflow credentials (HTTP Basic Auth) with your Airflow API details.
Set the BASE_URL and API_BASE_URL environment variables with your Airflow API endpoint.
Trigger the workflow by providing the dag_id, task_id, conf (optional), wait (optional), and wait_time (optional) as input.
The workflow will initiate the DAG run and proceed based on its status.

Apps Used

airflow

api

automation

dag-run

monitoring

Workflow JSON

{
  "id": "9dd68d73-2414-4b30-bf7d-e6e78055a6c8",
  "name": "Community Contributed Airflow Dag Run",
  "nodes": 0,
  "category": "Community Contributed",
  "status": "active",
  "version": "1.0.0"
}

Note: This is a sample preview. The full workflow JSON contains node configurations, credentials placeholders, and execution logic.