气流,获取当前dag运行中任务的当前状态



我有一个任务,通过它我可以向数据库写入哪些任务已成功处理。我正在尝试从我的python操作符中获取TaskInstance.current_status()。然而,我似乎找不到成功获得TaskInstance的方法。如何获取任务实例,传递给TaskInstance()?我试过task_id,但它似乎不能是字符串

看起来很简单:

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()      

最新更新