Airflow，获取当前 dag 运行中任务的当前状态

Question

我有一个任务，通过它我可以写入数据库，哪些任务已成功处理。我正在尝试从我的 python 操作员那里获取信息TaskInstance.current_status()。但是，我似乎找不到成功获取 TaskInstance 的方法。如何获取任务实例并传递给TaskInstance()？我试过了task_id，但似乎不能是字符串

Answer 1

看起来相当简单：

 from airflow.models import TaskInstance
 dag_instance = kwargs['dag']
 operator_instance = dag_instance.get_task("task_id")
 task_status = TaskInstance(operator_instance, execution_date).current_state()