Airflow Summit 2025 将于 10 月 07-09 日举行。立即注册享早鸟票!

airflow.example_dags.example_task_group_decorator

演示使用 @taskgroup 装饰器的示例 DAG。

属性

start_task

函数

task_start()

空的任务,它是 DAG 的第一个任务

task_1(value)

空的任务1

task_2(value)

空的任务2

task_3(value)

空的任务3

task_end()

空的任务,它是 DAG 的最后一个任务

task_group_function(value)

用于对相关任务进行分组的 TaskGroup

模块内容

airflow.example_dags.example_task_group_decorator.task_start()[source]

空的任务,它是 DAG 的第一个任务

airflow.example_dags.example_task_group_decorator.task_1(value)[source]

空的任务1

airflow.example_dags.example_task_group_decorator.task_2(value)[source]

空的任务2

airflow.example_dags.example_task_group_decorator.task_3(value)[source]

空的任务3

airflow.example_dags.example_task_group_decorator.task_end()[source]

空的任务,它是 DAG 的最后一个任务

airflow.example_dags.example_task_group_decorator.task_group_function(value)[source]

用于对相关任务进行分组的 TaskGroup

airflow.example_dags.example_task_group_decorator.start_task = '[Task_start]'[source]

此条目是否有帮助?