Update sync_table_with_pandas reference tasks

VincentAntoine · VincentAntoine · commit b863b96756ff · 2025-01-27T10:10:23.000+01:00
diff --git a/forklift/forklift/pipeline/flows/sync_table_with_pandas.py b/forklift/forklift/pipeline/flows/sync_table_with_pandas.py
@@ -140,5 +140,5 @@ def extract_df(
                 upstream_tasks=[post_processing],
             )
 
-flow.set_reference_tasks(loaded_df, final_drop_table)
+flow.set_reference_tasks([loaded_df, final_drop_table])
 flow.file_name = Path(__file__).name

Original file line number	Diff line number	Diff line change
`@@ -140,5 +140,5 @@ def extract_df(`
`140`	`140`	`upstream_tasks=[post_processing],`
`141`	`141`	`)`
`142`	`142`
`143`		`-flow.set_reference_tasks(loaded_df, final_drop_table)`
	`143`	`+flow.set_reference_tasks([loaded_df, final_drop_table])`
`144`	`144`	`flow.file_name = Path(__file__).name`