![]() ![]() This operator allows you to have a task in one DAG that triggers another DAG in the same Airflow environment. The TriggerDagRunOperator is a straightforward method of implementing cross-DAG dependencies from an upstream DAG. See Datasets and Data-Aware Scheduling in Airflow to learn more. One of those datasets has already been updated by an upstream DAG. The following image shows that the DAG dataset_dependent_example_dag runs only after two different datasets have been updated. In the Airflow UI, the Next Run column for the downstream DAG shows dataset dependencies for the DAG and how many dependencies have been updated since the last DAG run.
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |