airflow - 如何在气流中的 dag 中找到特定任务的开始日期和结束日期？
问题描述
我正在使用 kwargs['execution_date'] 来获取 dag 的执行日期，但它给出了调用整个 dag 的时间，但我需要特定任务在气流中开始和结束的时间。
解决方案
- 使用
get_task_instance()效用函数获得TaskInstance - 从
TaskInstance对象，你可以得到start_date&end_date
作为旁注，context/kwargs 确实包含 end_date& END_DATE（nodash-format），但不包含start_date