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()