有什么方法可以找到 DAG 中任何随机任务所花费的时间吗？
Is there any way to find the amount of time taken by any random task in DAG?
我需要通过 DAG 中的任何特定任务找到 时间量 。
例如：
SampleTask=DummyOperator(
task_id='SampleTask',
dag=dag)
现在我想知道根据task_id，上述任务所花费的时间如何，其他任务也是如此。
如果您从 Airflow UI 转到 Data Profiling > Ad Hoc Query，然后 select airflow_db 数据库，您可以发出此查询：
select execution_date, duration from task_instance where task_id = 'SampleTask'
duration 列保存任务的秒数 运行。
我需要通过 DAG 中的任何特定任务找到 时间量 。
例如：
SampleTask=DummyOperator(
task_id='SampleTask',
dag=dag)
现在我想知道根据task_id，上述任务所花费的时间如何，其他任务也是如此。
如果您从 Airflow UI 转到 Data Profiling > Ad Hoc Query，然后 select airflow_db 数据库，您可以发出此查询：
select execution_date, duration from task_instance where task_id = 'SampleTask'
duration 列保存任务的秒数 运行。