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 物件的關鍵字引數。