我知道以前有人问过这个问题,但我想把它说得很简单。我正在使用Astronomer运行Airflow v1.10.10。每个dag运行(每天)可以有不同数量的任务。此任务数将由给定dag运行(即当天)的数据库表中的行数定义。我将在dag文件中运行一个查询,并创建一个如下列表:
list = client.query(SELECT * FROM TA
我有一系列任务,用于启动容器并在其中运行python脚本。但是,我需要挂载包含python代码的卷...在遇到许多错误后,我发现不再支持添加卷,现在必须指定一个装载对象:https://github.com/apache/airflow/pull/15843 我的任务代码如下所示: from airflow.operators.docker_operator,我运行的