Apache Airflow - ExternalTaskSensor，如何使用'execution_date_fn‘返回execution_date

Question

如果上游dags是动态触发的，则会为它们分配粒度“execution_date”，而不是调度程序分配的dd-mm-yyyy hh:00:00。在这种情况下，我们需要实现一个'execution_date_fn‘In传感器，它通过元数据db查找确切的执行时间来戳到状态。

我们需要检查/测试这是否可以在此场景中实现。

Answer 1

在我的例子中是一个简单的例子。

import pendulum

def get_execution_date(dt):
    print('Original execution_date: ' + str(dt))
    return pendulum.datetime(2019, 5, 11, 11, 36, 54, 894008)