fix

moj-analytical-services · Apr 16, 2024 · 5937918 · 5937918
1 parent 610d33b
commit 5937918
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/splink/vertically_concatenate.py b/splink/vertically_concatenate.py
@@ -54,12 +54,12 @@ def vertically_concatenate_sql(
     if len(input_tables) > 1:
         sqls_to_union = []
 
-        if source_dataset_column_already_exists:
-            create_sds_if_needed = ""
-        else:
-            create_sds_if_needed = f"'{df_obj.templated_name}' as source_dataset,"
-
         for df_obj in input_tables.values():
+            if source_dataset_column_already_exists:
+                create_sds_if_needed = ""
+            else:
+                create_sds_if_needed = f"'{df_obj.templated_name}' as source_dataset,"
+
             sql = f"""
             select
             {create_sds_if_needed}