airflow - 气流，在当前 dag 运行中获取任务的当前状态

Question

我有一个任务，我通过它写入 db 哪些任务已成功处理。我正在尝试TaskInstance.current_status()从我的 python 操作员那里获取信息。但是，我似乎找不到成功获取 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()