{
  "openruna_format": "flow-graph-v1",
  "title": "airflow dag_run",
  "slug": "airflow-dag-run",
  "source_filename": "1768_Stopanderror_Wait_Automation_Webhook.json",
  "nodes": [
    {
      "id": "Airflow: dag_run",
      "name": "Airflow: dag_run",
      "integration": "httpRequest",
      "kind": "action"
    },
    {
      "id": "Airflow: dag_run - state",
      "name": "Airflow: dag_run - state",
      "integration": "httpRequest",
      "kind": "action"
    },
    {
      "id": "count",
      "name": "count",
      "integration": "code",
      "kind": "logic"
    },
    {
      "id": "dag run fail",
      "name": "dag run fail",
      "integration": "stopAndError",
      "kind": "action"
    },
    {
      "id": "if state == queued",
      "name": "if state == queued",
      "integration": "if",
      "kind": "logic"
    },
    {
      "id": "dag run wait too long",
      "name": "dag run wait too long",
      "integration": "stopAndError",
      "kind": "action"
    },
    {
      "id": "Airflow: dag_run - get result",
      "name": "Airflow: dag_run - get result",
      "integration": "httpRequest",
      "kind": "action"
    },
    {
      "id": "Switch: state",
      "name": "Switch: state",
      "integration": "switch",
      "kind": "logic"
    },
    {
      "id": "in data",
      "name": "in data",
      "integration": "executeWorkflow",
      "kind": "trigger"
    },
    {
      "id": "Wait",
      "name": "Wait",
      "integration": "wait",
      "kind": "logic"
    },
    {
      "id": "If count > wait_time",
      "name": "If count > wait_time",
      "integration": "if",
      "kind": "logic"
    },
    {
      "id": "airflow-api",
      "name": "airflow-api",
      "integration": "set",
      "kind": "logic"
    }
  ],
  "edges": [
    {
      "from": "Wait",
      "to": "Airflow: dag_run - state"
    },
    {
      "from": "count",
      "to": "If count > wait_time"
    },
    {
      "from": "in data",
      "to": "airflow-api"
    },
    {
      "from": "airflow-api",
      "to": "Airflow: dag_run"
    },
    {
      "from": "Switch: state",
      "to": "Airflow: dag_run - get result"
    },
    {
      "from": "Switch: state",
      "to": "count"
    },
    {
      "from": "Switch: state",
      "to": "count"
    },
    {
      "from": "Switch: state",
      "to": "dag run fail"
    },
    {
      "from": "Airflow: dag_run",
      "to": "if state == queued"
    },
    {
      "from": "if state == queued",
      "to": "Wait"
    },
    {
      "from": "if state == queued",
      "to": "dag run fail"
    },
    {
      "from": "If count > wait_time",
      "to": "dag run wait too long"
    },
    {
      "from": "If count > wait_time",
      "to": "Wait"
    },
    {
      "from": "Airflow: dag_run - state",
      "to": "Switch: state"
    }
  ]
}