在Airflow的仪表盘中显示任务描述,可以通过在DAG文件中的任务定义中添加docstring,并在仪表盘的任务列表中显示出来。
以下是一个示例代码,演示如何在Airflow的仪表盘中显示任务描述:
from datetime import datetime
from airflow import DAG
from airflow.operators.dummy_operator import DummyOperator
default_args = {
'owner': 'airflow',
'start_date': datetime(2021, 1, 1),
}
with DAG('task_description_example', default_args=default_args, schedule_interval='@daily') as dag:
def task_description():
"""
This is a sample task description.
It will be displayed in the Airflow dashboard.
"""
start = DummyOperator(task_id='start')
end = DummyOperator(task_id='end')
task_with_description = DummyOperator(task_id='task_with_description', dag=dag)
task_with_description.doc_md = task_description.__doc__
start >> task_with_description >> end
在上面的示例中,我们创建了一个名为task_description_example
的DAG,并在其中定义了一个名为task_with_description
的任务。我们在任务定义中添加了一个名为task_description
的函数,并在函数的docstring中编写了任务描述。
然后,我们将任务的doc_md
属性设置为task_description.__doc__
,这将任务的描述添加到仪表盘中。
注意,为了确保任务描述在仪表盘中显示,需要将task_with_description
任务添加到DAG中。