From eb23090f46134deb453f03d5420f5c605afdbb5e Mon Sep 17 00:00:00 2001
From: Saket <52213128+saket04@users.noreply.github.com>
Date: Wed, 30 Sep 2020 20:55:48 +0530
Subject: [PATCH] update example.py

---
 dags/example_python_operator.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/dags/example_python_operator.py b/dags/example_python_operator.py
index 0fc2180..85a5ec5 100644
--- a/dags/example_python_operator.py
+++ b/dags/example_python_operator.py
@@ -47,4 +47,5 @@ def print_context(ds, **kwargs):
         op_kwargs={'random_base': float(i)/10},
         dag=dag)
 
-    task.set_upstream(run_this)
+    #task.set_upstream(run_this)
+    run_this >> task