最近,我将Airflow从1.9升级到1.10.3 (最新版本)。# the max number of task instances that should run simultaneously
# on this airflow installation# The concurrency that will be used
我一直在尝试在气流中使用“example_subdag_operator”。在我将“start_date”更改为“datetime.now()”之后,然后手动触发一个dag运行。from datetime import datetime
from airflow.operators.dummy_operator importDummyOperator
from airflow.operators.subdag_operator import
requirements.txt这是代码 from airflow.operators.subdag_operatorimport SubDagOperator from o2a.o2a_libs import functionsfrom airflow.models import Variable
import s