仅当使用Python中的DAG在AWS athena表中可用新分区/数据时,如何触发Airflow任务?
我有一个类似下面的情况:
Trigger a Task 1 and Task 2 only when new data is avialable for them in source table ( Athena). Trigger for Task1 and Task2 should happen when a new data parition in a day.
Trigger Task 3 only on the completion of Task 1 and Task 2
Trigger Ta...