气流何时为2.5.*可在云作曲家的图像?



我看到气流2.5.0在2022-12-02发布。什么时候可以在云作曲器图像中使用?

我想迭代前一个任务输出的项目列表以创建动态task_group,类似于这里的问题
我理解task_groups的expand()方法的实现仅从气流2.5中可用。因此,我想知道何时这将成为可用的云作曲家

@dag(
'my_dag',
schedule = None,
catchup=False,
default_args=default_dag_args
)
def taskflow():
@task
def generate_data() -> List[str]:
return ['data1', 'data2', 'data3']

@task_group
def task_group_tasks(d):
task_1  = BashOperator(task_id=f'task_1_{d}', bash_command='exit 0')
task_2  = BashOperator(task_id=f'task_2_{d}', bash_command='exit 0')
task_1 >> task_2

list_data = generate_data()
task_group_tasks.expand(data=list_data)
dag = taskflow()

截至目前,最新的气流版本,目前可与云作曲家的图像是airflow-2.4.3。关于它(airflow-2.5.*)与Cloud Composer的可用性,目前还没有公告。同时,您可以不时访问Cloud Composer的发布说明,以便随时了解最新情况。此外,您可以查看"气流"的发行说明。

相关内容

  • 没有找到相关文章

最新更新