diff --git a/airflow/example_dags/example_skip_dag.py b/airflow/example_dags/example_skip_dag.py index b4b24826638d7..b55c3a8587936 100644 --- a/airflow/example_dags/example_skip_dag.py +++ b/airflow/example_dags/example_skip_dag.py @@ -44,12 +44,6 @@ def create_test_pipeline(suffix, trigger_rule, dag): join = DummyOperator(task_id=trigger_rule, dag=dag, trigger_rule=trigger_rule) - - op = MyEmrOperator(task_id='my_task_id', dag=dag, - template='my_jinja_template.conf', - params={ 'param1': '{{ ti.xcom_pull(...) }}' } - ) - join.set_upstream(skip_operator) join.set_upstream(always_true) diff --git a/tests/core.py b/tests/core.py index 2597e7677db53..c73b66f7ee214 100644 --- a/tests/core.py +++ b/tests/core.py @@ -35,7 +35,7 @@ import six -NUM_EXAMPLE_DAGS = 14 +NUM_EXAMPLE_DAGS = 15 DEV_NULL = '/dev/null' TEST_DAG_FOLDER = os.path.join( os.path.dirname(os.path.realpath(__file__)), 'dags')