From cffb036428bf6ed147da23f11b19e0493b86d991 Mon Sep 17 00:00:00 2001 From: Neel Dalsania Date: Tue, 17 May 2022 15:20:02 +0530 Subject: [PATCH] moved from dummy operator to empty operator (#535) --- airflow/include/exampledag.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/airflow/include/exampledag.go b/airflow/include/exampledag.go index b54ffc60c..bdb933f77 100644 --- a/airflow/include/exampledag.go +++ b/airflow/include/exampledag.go @@ -8,7 +8,7 @@ from datetime import datetime, timedelta from airflow import DAG from airflow.operators.bash import BashOperator -from airflow.operators.dummy import DummyOperator +from airflow.operators.empty import EmptyOperator from airflow.operators.python import PythonOperator @@ -45,9 +45,9 @@ with DAG( # catchup=False # enable if you don't want historical dag runs to run ) as dag: - t0 = DummyOperator(task_id='start') + t0 = EmptyOperator(task_id='start') - t1 = DummyOperator(task_id='group_bash_tasks') + t1 = EmptyOperator(task_id='group_bash_tasks') t2 = BashOperator(task_id='bash_print_date1', bash_command='sleep $[ ( $RANDOM % 30 ) + 1 ]s && date') t3 = BashOperator(task_id='bash_print_date2', bash_command='sleep $[ ( $RANDOM % 30 ) + 1 ]s && date')