Google Cloud Composer - Manually trigger DAG runs using Airflow v1.10+

google_cloud_composer_manually_trigger_dag.sh

# Google Cloud Composer - Manually trigger DAG runs using Airflow v1.10+
ENVIRONMENT_NAME=my-composer
LOCATION=us-east1

# Trigger DAG - individual
DAG_ID=my_daily_dag
EXEC_DATE=2019-02-11
gcloud composer environments run ${ENVIRONMENT_NAME} --location ${LOCATION} trigger_dag -- -r manual__${EXEC_DATE} -e ${EXEC_DATE} ${DAG_ID}

# Trigger DAG - multiple
DAG_ID=my_daily_dag
DATES=(
    2019-02-11
    2019-02-10
    2019-02-09
    ...
    2019-01-01
    )
for EXEC_DATE in ${DATES[*]}
do
    echo "Creating DAG Run for: ${EXEC_DATE}"
    gcloud composer environments run ${ENVIRONMENT_NAME} --location ${LOCATION} trigger_dag -- -r manual__${EXEC_DATE} -e ${EXEC_DATE} ${DAG_ID}
done