在SubdagOperator中添加'concurrency'参数可以解决该问题。例如:
from airflow import DAG
from airflow.operators.subdag_operator import SubDagOperator
from subdag import subdag
dag = DAG(
dag_id='parent_dag',
)
subdag_operator = SubDagOperator(
task_id='subdag_task',
subdag=subdag('parent_dag', 'subdag_task'),
dag=dag,
concurrency=1 # 添加并发参数
)
此外,还可以升级Airflow版本到1.10.15以上来解决死锁问题。
上一篇:Airflow1.10.10[core]vs1.10.15[logging]AWSS3RemoteLogging”
下一篇:Airflow1.10.15-HooksthatrunDBfunctionsmustinheritfromDBApiHook