각 Airflow DAG마다 다른 실행 프로그램을 설정할 수 있습니까?

Question

기존 기류 서버에 다른 DAG를 추가하려고합니다. 서버는 현재 LocalExecutor를 사용하고 있지만 DAG에서 CeleryExecutor를 사용할 수 있습니다. 이 구성 파일처럼 보인다 airflow.cfg만을 허용 한 집행 :

# The executor class that airflow should use. Choices include 
# SequentialExecutor, LocalExecutor, CeleryExecutor 
executor = LocalExecutor 

는 기존 DAG를가 CeleryExecutor 또는 사용자 정의 실행기 클래스를 사용할 수 있습니다 LocalExecutor 내 새 DAG를 계속 사용할 수 있도록 공기 흐름을 구성 할 수 있습니까? 나는 이것을하는 사람들의 사례를 발견하지 못했고, Airflow 문서에서 어떤 것도 발견하지 못했습니다.

Answer 1

스케줄러가 실행 프로그램 인스턴스 하나만 시작하는 것 같습니다.

Answer 2

DAG 내에 SubDAG가있는 경우 특정 Executor를 해당 SubDagOperator에 전달할 수 있습니다. 예를 들어, SequentialExecutor를 사용하는 경우 :

bar_subdag = SubDagOperator(
    task_id='bar', 
    subdag=my_subdag('foo', 'bar', default_args), 
    default_args=default_args, 
    dag=foo_dag, 
    executor=SequentialExecutor() 
) 

이것은 1.8에 해당하며, 1.9가 다른지 확실하지 않습니다.