Воздушный поток, получить текущее состояние задачи в текущем цикле запуска

Question

У меня есть задача, с помощью которой я пишу в БД, какие задачи были успешно обработаны.Я пытаюсь получить 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()