Sign in
dags

Execute DAG synchronously and wait for completion

Creates a DAG-run from the DAG definition, starts its execution, waits for it to complete (or timeout), and returns the full execution details including node statuses.

Important behaviors:

  • If the timeout is exceeded, the DAG run continues executing in the background. The 408 response includes the dagRunId so clients can monitor or cancel the run.
  • If the DAG reaches a 'waiting' status (human-in-the-loop approval needed), the endpoint returns immediately with 200 and the current status.
post/dags/{fileName}/start-sync

Path parameters

fileNamestring regex required

Name of the DAG file

the name of the DAG file

Query parameters

remoteNodestring

name of the remote node

Request body

paramsstring

Parameters to pass to the DAG-run in JSON format

dagRunIdstring

Optional ID for the DAG-run, if not provided a new one will be generated

dagNamestring

Optional DAG name override to use for the created dag-run

singletonboolean

If true, prevent starting if DAG is already running (returns 409 conflict)

labelsstring[]

Additional labels to apply to the DAG-run (format: key=value or key-only). Merged with labels defined in the DAG spec. Mutually exclusive with deprecated tags; the server returns HTTP 400 if both are set.

tagsstring[]

Deprecated alias for Labels. Additional labels to apply to the DAG-run (format: key=value or key-only). Merged with labels defined in the DAG spec. Mutually exclusive with labels; the server returns HTTP 400 if both are set.

timeoutinteger required

Maximum seconds to wait for DAG execution to complete (required)

Example request

{
  "dagRunId": "latest"
}

Response

DAG-run completed (or reached waiting status)

Example response

{
  "dagRun": {
    "dagRunId": "latest",
    "rootDAGRunId": "latest",
    "parentDAGRunId": "latest",
    "nodes": [
      {
        "subRuns": [
          {
            "dagRunId": "latest"
          }
        ],
        "subRunsRepeated": [
          {
            "dagRunId": "latest"
          }
        ]
      }
    ],
    "onExit": {
      "subRuns": [
        {
          "dagRunId": "latest"
        }
      ],
      "subRunsRepeated": [
        {
          "dagRunId": "latest"
        }
      ]
    },
    "onSuccess": {
      "subRuns": [
        {
          "dagRunId": "latest"
        }
      ],
      "subRunsRepeated": [
        {
          "dagRunId": "latest"
        }
      ]
    },
    "onFailure": {
      "subRuns": [
        {
          "dagRunId": "latest"
        }
      ],
      "subRunsRepeated": [
        {
          "dagRunId": "latest"
        }
      ]
    },
    "onAbort": {
      "subRuns": [
        {
          "dagRunId": "latest"
        }
      ],
      "subRunsRepeated": [
        {
          "dagRunId": "latest"
        }
      ]
    }
  }
}

Changes