Trigger DAG Runs
Trigger one or more Airflow DAG runs, optionally waiting for completion with live progress and task logs.paradime run airflow-trigger \
--dag-ids "my_dag_id"
| Flag | Type | Description |
|---|---|---|
--base-url | Required, TEXT | Your Airflow base URL (e.g., https://your-airflow.com, MWAA webserver URL, or Cloud Composer URL). Can be set via AIRFLOW_BASE_URL environment variable. |
--username | Optional, TEXT | Your Airflow username or API key. Not required for GCP Cloud Composer with —use-gcp-auth. Can be set via AIRFLOW_USERNAME environment variable. |
--password | Optional, TEXT | Your Airflow password or API secret. Not required for GCP Cloud Composer with —use-gcp-auth. Can be set via AIRFLOW_PASSWORD environment variable. |
--bearer-token | Optional, TEXT | Optional bearer token for token-based authentication. Not required for basic auth or GCP. Can be set via AIRFLOW_BEARER_TOKEN environment variable. |
--use-gcp-auth | Optional, Flag | Use GCP Cloud Composer authentication (Application Default Credentials). Default: False. |
--dag-ids | Required, TEXT | Comma-separated DAG ID(s) to trigger. |
--dag-run-conf | Optional, TEXT | Optional JSON configuration to pass to DAG runs (as a string). |
--logical-date | Optional, TEXT | Optional logical date for DAG runs in ISO format (e.g., ‘2024-01-01T00:00:00Z’). Defaults to current timestamp. |
--wait / --no-wait | Optional, Flag | Wait for DAG runs to complete before returning. Default: --wait. Can be set via AIRFLOW_TRIGGER_WAIT environment variable. |
--timeout | Optional, INTEGER | Maximum time to wait in minutes. Default: 1440. Can be set via AIRFLOW_TRIGGER_TIMEOUT environment variable. |
--poll-interval | Optional, INTEGER | Seconds between status polls; also the log-tail cadence. Default: 10. Can be set via AIRFLOW_POLL_INTERVAL environment variable. |
--show-logs / --no-show-logs | Optional, Flag | Display task logs during execution. Only used with —wait. Default: --show-logs. |
--json | Optional, Flag | Output results as JSON. Default: False. |
--help | Show CLI command options and exit. |
paradime run airflow-trigger \
--dag-ids "sales_pipeline,marketing_pipeline" \
--dag-run-conf '{"run_date": "2024-01-01"}'
List DAGs
List all available Airflow DAGs with their status.paradime run airflow-list-dags
| Flag | Type | Description |
|---|---|---|
--base-url | Required, TEXT | Your Airflow base URL (e.g., https://your-airflow.com, MWAA webserver URL, or Cloud Composer URL). Can be set via AIRFLOW_BASE_URL environment variable. |
--username | Optional, TEXT | Your Airflow username or API key. Not required for GCP Cloud Composer with —use-gcp-auth. Can be set via AIRFLOW_USERNAME environment variable. |
--password | Optional, TEXT | Your Airflow password or API secret. Not required for GCP Cloud Composer with —use-gcp-auth. Can be set via AIRFLOW_PASSWORD environment variable. |
--bearer-token | Optional, TEXT | Optional bearer token for token-based authentication. Not required for basic auth or GCP. Can be set via AIRFLOW_BEARER_TOKEN environment variable. |
--use-gcp-auth | Optional, Flag | Use GCP Cloud Composer authentication (Application Default Credentials). Default: False. |
--only-active | Optional, Flag | Only show active (non-paused) DAGs. Default: True. |
--json | Optional, Flag | Output results as JSON. Default: False. |
--help | Show CLI command options and exit. |