有没有办法找到DAG中任何随机任务所花费的时间

Question

我需要在DAG中查找任何特定任务的时间量。

例如：

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

现在我想知道上述任务所花费的时间如何基于其task_id，以及其他任务所花费的时间。

Answer 1

如果从 Airflow UI 转到"数据概要>即席查询"，然后选择airflow_db数据库，则可以发出以下查询：

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

duration列保存任务运行的秒数。