(5/5)

airflow dag_run

Automated workflow: airflow dagrun. This workflow processes data and performs automated tasks.

Integrations Used (2)

HTTP Request

Executeworkflow

Workflow Structure (12 nodes)

100%

Execute Workflow Trigger

in data

Set

airflow-api

Http Request

Airflow: dag_run

if state == queued

Wait

Http Request

Airflow: dag_run - state

Switch

Switch: state

Code

count

Http Request

Airflow: dag_run - get result

Stop And Error

dag run wait too long

Stop And Error

dag run fail

If count > wait_time

Node Types:

http

code

default

logic

trigger

transform

Requires credentials

Prerequisites

Required Credentials (1)

HTTP Basic Auth

Used by: Airflow: dag_run, Airflow: dag_run - state +1 more

Docs

Complexity

Complex

Advanced features used. Requires n8n experience.

Setup time: ~30 min

Score: 58/100

Custom Code

Conditional Logic

When to Use This Workflow

Real-time Response

React instantly when events happen - new orders, form submissions, or API calls.

Zero delay between trigger and action for time-sensitive workflows.

Time Savings

Replace repetitive manual tasks with reliable automation.

Reclaim hours every week for higher-value work.

Error Reduction

Eliminate human error from routine processes with consistent automation.

Improve accuracy and reliability across your workflows.

workflow.json

{
  "id": "Y5URlIlbX4HDzWKA",
  "meta": {
    "instanceId": "workflow-d3eadf4d",
    "versionId": "1.0.0",
    "createdAt": "2025-09-29T07:07:55.724749",
    "updatedAt": "2025-09-29T07:07:55.724767",
    "owner": "n8n-user",
    "license": "MIT",
    "category": "automation",
    "status": "active",
    "priority": "high",
    "environment": "production"
  },
  "name": "airflow dag_run",
  "tags": [
    "automation",
    "n8n",
    "production-ready",
    "excellent",
...