airflow dag_run

Manual

High

Nodes

Manual

Trigger

High

Complexity

7/22/2025

Added

Workflow Overview

Total Nodes

Node Types

http Request

Airflow: dag_run, Airflow: dag_run - state, Airflow: dag_run - get result

3 nodes

code

count

1 node

stop And Error

dag run fail, dag run wait too long

2 nodes

if state == queued, If count > wait_time

2 nodes

switch

Switch: state

1 node

execute Workflow Trigger

in data

1 node

wait

Wait

1 node

set

airflow-api

1 node

Workflow JSON

13.2 KB

{
  "id": "Y5URlIlbX4HDzWKA",
  "meta": {
    "instanceId": "6ae0aa8b6c9099f1f8ed1265281802eab47aaf5b2845f317791e4ac7ee5b7279",
    "templateCredsSetupCompleted": true
  },
  "name": "airflow dag_run",
  "tags": [
    {
      "id": "YSelDQ3zfWB0LeVn",
      "name": "airflow",
      "createdAt": "2025-02-25T04:17:21.943Z",
      "updatedAt": "2025-02-25T04:17:21.943Z"
    }
  ],
  "nodes": [
    {
      "id": "0d4457ef-7a88-4755-8bd2-b0e8148f86f4",
      "name": "Airflow: dag_run",
      "type": "n8n-nodes-base.httpRequest",
      "position": [
        380,
        -40
      ],
      "parameters": {
        "url": "={{ $('airflow-api').item.json.prefix }}/api/v1/dags/{{ $('in data').item.json.dag_id }}/dagRuns",
        "method": "POST",
        "options": {},
        "jsonBody": "={\n  \"conf\": {{ $('in data').item.json.conf }}\n}",
        "sendBody": true,
        "specifyBody": "json",
        "authentication": "genericCredentialType",
        "genericAuthType": "httpBasicAuth"
   ...

Showing first 1000 characters. Click "Expand" to view the full JSON.