有什么方法可以计算出DAG中任意一个随机任务所花费的时间吗？

Question

我需要通过DAG中的任何特定任务找到时间量。

例如：

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

现在我想知道上面的任务所花费的时间是基于它的任务标识的，其他任务也是如此。在

Answer 1

如果从Airflow UI转到Data Profiling>；Ad Hoc Query，并选择airflow_db数据库，则可以发出以下查询：

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

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