Airflow Operator : DummyOperator (아무 기능이 없는 operator)

 

 

 

DummyOperator는 아무 기능을 하지 않는 Operator입니다.

아무 기능을 하지 않는데 왜 필요하지 라고 생각할 수 있지만

실제로 복잡한 pipeline을 구성하다보면 pipeline을 더 가독성있게 구성하기 위해 아무 기능은 안하지만 의도적으로 flow를 고정시키고 싶다던가,

아니면 병렬 <-> 병렬 task간의 연결은 직접적으로 할 수 없기 때문에 병렬 -> dummy operator -> 병렬 이런식으로 flow를 구성한다던가 등의 경우에 DummyOperator가 유용하게 쓰입니다.

 

 

from airflow import DAG

dag = DAG(
    dag_id='test_dag',
    start_date=datetime.datetime(2022, 9, 27),
    schedule_interval='0 20 * * *'
)


from airflow.operators.dummy import DummyOperator  # 1

op_test_dummy = DummyOperator(  # 2
    dag=dag,  # 3
    task_id='test_dummy',  # 4
)

 

# 1
DummyOperator를 사용하기 위해선 import를 먼저 해야합니다.
DummyOperator의 위치는 airflow 버전 등에 따라 달라질 수 있습니다.

# 2
DummyOperator를 호출합니다.

# 3
Operator가 어느 dag에 속하는지 dag 정보를 전달합니다.

# 4
DummyOperator의 task_id입니다. Operator의 이름입니다.