From b5f8ab5ca197da2acb8e40a70315fe4c50f1069b Mon Sep 17 00:00:00 2001
From: Siddharth Anand <sanand@agari.com>
Date: Wed, 6 Apr 2016 16:59:43 -0700
Subject: [PATCH] Fixing a broken example dag, example_skip_dag.py

---
 airflow/example_dags/example_skip_dag.py | 6 ------
 tests/core.py                            | 2 +-
 2 files changed, 1 insertion(+), 7 deletions(-)

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')