From 909fa1513155325f021927da12ce12877128ae60 Mon Sep 17 00:00:00 2001 From: ewelinagr Date: Wed, 11 May 2022 10:51:33 +0200 Subject: [PATCH] Fix order of subtasks for main data loading task. --- luigi-pipeline/main.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/luigi-pipeline/main.py b/luigi-pipeline/main.py index a52f214..78262ef 100644 --- a/luigi-pipeline/main.py +++ b/luigi-pipeline/main.py @@ -209,7 +209,7 @@ def _build_task_dependency_tree(self): yield commit_input_data sources_to_csr_task = Sources2CsrTransformation() - sources_to_csr_task.required_tasks = [update_data_files] + sources_to_csr_task.required_tasks = [commit_input_data] yield sources_to_csr_task csr_to_transmart_task = TransmartDataTransformation()