Fix order of subtasks for main data loading task.

thehyve · May 11, 2022 · 909fa15 · 909fa15
1 parent 82dfb28
commit 909fa15
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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()