Есть ли способ найти количество времени, затрачиваемое на любую случайную задачу в DAG?

Question

У меня есть требование найти количество времени по любой конкретной задаче в DAG .

Например:

SampleTask=DummyOperator(
    task_id='SampleTask',
    dag=dag)

Теперь я хочу узнать, как время, затрачиваемое на вышеуказанную задачу, основано на ее task_id, и таким же образом для других задач.

Answer 1

Если перейти к Профилирование данных> Специальный запрос из пользовательского интерфейса Airflow и выбрать базу данных airflow_db, вы можете выполнить этот запрос:

select execution_date, duration from task_instance where task_id = 'SampleTask'

duration В столбце указывается количество секунд, в течение которых было выполнено задание.