changed upstream order for df_validation

Diego-H-S · Mar 15, 2024 · f5ac927 · f5ac927
1 parent 8d12bc1
commit f5ac927
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/viadot/flows/adls_to_azure_sql.py b/viadot/flows/adls_to_azure_sql.py
@@ -369,8 +369,8 @@ def gen_flow(self) -> Flow:
             if self.validate_df_dict:
                 validate_df.bind(df=df, tests=self.validate_df_dict, flow=self)
                 validate_df.set_upstream(lake_to_df_task, flow=self)
+                df_reorder.set_upstream(validate_df, flow=self)
 
-            df_reorder.set_upstream(lake_to_df_task, flow=self)
             df_to_csv.set_upstream(df_reorder, flow=self)
             promote_to_conformed_task.set_upstream(df_to_csv, flow=self)
             create_table_task.set_upstream(df_to_csv, flow=self)