From 65104d5a2d454f9906b150001190e496290fbe36 Mon Sep 17 00:00:00 2001 From: Jean-Baptiste Pressac Date: Wed, 12 Jan 2022 18:10:07 +0100 Subject: [PATCH] renamed join_erp to join_erp_branch There is also an error in Listing 5.15 in the book... --- chapter05/dags/04_branch_dag_join.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/chapter05/dags/04_branch_dag_join.py b/chapter05/dags/04_branch_dag_join.py index 1aad3910..274a8370 100644 --- a/chapter05/dags/04_branch_dag_join.py +++ b/chapter05/dags/04_branch_dag_join.py @@ -55,7 +55,7 @@ def _clean_sales_new(**context): task_id="clean_sales_new", python_callable=_clean_sales_new ) - join_erp = DummyOperator(task_id="join_erp_branch", trigger_rule="none_failed") + join_erp_branch = DummyOperator(task_id="join_erp_branch", trigger_rule="none_failed") fetch_weather = DummyOperator(task_id="fetch_weather") clean_weather = DummyOperator(task_id="clean_weather") @@ -68,7 +68,7 @@ def _clean_sales_new(**context): pick_erp_system >> [fetch_sales_old, fetch_sales_new] fetch_sales_old >> clean_sales_old fetch_sales_new >> clean_sales_new - [clean_sales_old, clean_sales_new] >> join_erp + [clean_sales_old, clean_sales_new] >> join_erp_branch fetch_weather >> clean_weather - [join_erp, clean_weather] >> join_datasets + [join_erp_branch, clean_weather] >> join_datasets join_datasets >> train_model >> deploy_model