trigger_dag
Trigger a manual DAG run in an Airflow development cluster. Optionally pass configuration, set logical date, or attach a note.
Instructions
Trigger a manual run of a DAG in the dev Airflow cluster.
Args:
dag_id: DAG identifier as it appears in Airflow.
conf: Optional dict passed to the run (accessible as dag_run.conf inside tasks).
logical_date: Optional ISO-8601 timestamp for the run's logical date. Defaults to now.
note: Optional human-readable note attached to the run.
Returns:
DagRunSummary for the created run, including dag_run_id needed for status/log lookups.
Note: if the DAG is paused, the run is created in queued state but will not execute
until the DAG is unpaused (see set_dag_paused).
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| conf | No | ||
| note | No | ||
| dag_id | Yes | ||
| logical_date | No |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
| conf | No | ||
| note | No | ||
| state | No | ||
| dag_id | No | ||
| end_date | No | ||
| run_type | No | ||
| dag_run_id | No | ||
| start_date | No | ||
| logical_date | No |