airflow.decorators.task_group¶
实现 @task_group 函数装饰器。
当调用被装饰的函数时，将创建一个任务组来表示同一 DAG 上的一组密切相关的任务，这些任务在以图形方式显示 DAG 时应分组在一起。
模块内容¶
函数¶
|
Python TaskGroup 装饰器。 |
属性¶
- airflow.decorators.task_group.task_group(group_id: str | None = None, prefix_group_id: bool = True, parent_group: airflow.utils.task_group.TaskGroup | None = None, dag: airflow.models.dag.DAG | None = None, default_args: dict[str, Any] | None = None, tooltip: str = '', ui_color: str = 'CornflowerBlue', ui_fgcolor: str = '#000', add_suffix_on_collision: bool = False) Callable[[Callable[FParams, FReturn]], _TaskGroupFactory[FParams, FReturn]][源代码]¶
- airflow.decorators.task_group.task_group(python_callable: Callable[FParams, FReturn]) _TaskGroupFactory[FParams, FReturn]
Python TaskGroup 装饰器。
这将一个函数包装到 Airflow TaskGroup 中。当用作
@task_group()形式时，所有参数都会转发到基础 TaskGroup 类。可用于参数化 TaskGroup。- 参数
python_callable – 要装饰的函数。
tg_kwargs – TaskGroup 对象的关键字参数。