Airflow DAGs
CertifiedTasks that trigger and monitor Apache Airflow DAG runs.
Trigger DAG executions through Airflow's REST API with required baseUrl and dagId, optionally pass a custom body payload for conf, and authenticate via headers or HTTP options such as basic auth or bearer tokens. Enable wait with pollFrequency and maxDuration to track completion and return run details including dagRunId, state, started, and ended timestamps.
Airflow DAGs
Tasks that trigger and monitor Apache Airflow DAG runs.
Trigger DAG executions through Airflow's REST API with required baseUrl and dagId, optionally pass a custom body payload for conf, and authenticate via headers or HTTP options such as basic auth or bearer tokens. Enable wait with pollFrequency and maxDuration to track completion and return run details including dagRunId, state, started, and ended timestamps.
How to use the Airflow plugin
Trigger Airflow DAG runs from Kestra flows and optionally wait for completion.
Authentication
Set baseUrl to your Airflow instance URL (e.g. http://localhost: 8080). Pass credentials via options (e.g. basic auth username and password via options.auth) or via custom headers. Store secrets in secrets and apply connection properties globally with plugin defaults.
Tasks
dags.TriggerDagRun triggers a DAG run — set dagId (required). Pass run configuration via body as a map. By default the task returns immediately after triggering (wait: false); set wait: true to poll until the run reaches a terminal state. Control polling with pollFrequency (default 1 second) and cap wait time with maxDuration (default 60 minutes).
