mds6_rdd_dags dz7_v8

Author: DR24DR24

dags/rdd/dz7.py

@@ -82,7 +82,7 @@ def branch_by_medal(ti, **kwargs):
         else:
             return 'count_gold'
 
-    branch_task = BranchPythonOperator(
+    branch_task = PythonOperator(
         task_id='branch_by_medal',
         python_callable=branch_by_medal,
         provide_context=True