有没有一种方法可以通过 group_id 来引用 Airflow 任务组,类似于引用任务 dag_instance.get_task('task_name')?
Is there a way to reference Airflow task group by group_id similar to referencing tasks dag_instance.get_task('task_name')?
我正在尝试找到一种通过 ID 引用任务组的方法。
类似于:
dag.get_group('group_id')
我知道如何使用 get_task('task_id')
方法获取任务实例,但奇怪的是我找不到对 TaskGroup 对象执行相同操作的方法。
您知道任何解决方法吗?
这应该有效:
tg = dag.task_group.get_child_by_label(group_id)
我正在尝试找到一种通过 ID 引用任务组的方法。 类似于:
dag.get_group('group_id')
我知道如何使用 get_task('task_id')
方法获取任务实例,但奇怪的是我找不到对 TaskGroup 对象执行相同操作的方法。
您知道任何解决方法吗?
这应该有效:
tg = dag.task_group.get_child_by_label(group_id)