Update passfail.py

passfail.py

@@ -2,6 +2,7 @@ from airflow import DAG
 from datetime import datetime, timedelta
 from airflow.contrib.operators.kubernetes_pod_operator import KubernetesPodOperator
 from airflow.operators.dummy_operator import DummyOperator
+from airflow.operators.bash import BashOperator
 
 
 default_args = {
@@ -43,5 +44,17 @@ failing = KubernetesPodOperator(namespace='default',
                           dag=dag
                           )
 
-passing.set_upstream(start)
-failing.set_upstream(start)
+templated_command = """
+kubectl get pods
+"""
+
+run_this = BashOperator(
+    task_id='bash_test',
+    bash_command=templated_command,
+    dag=dag,
+)
+
+start >> passing >> run_this
+start >> failing
+# passing.set_upstream(start)
+# failing.set_upstream(start)