revert

datayoga-io · Nov 29, 2023 · 2624056 · 2624056
1 parent f7b8e9e
commit 2624056
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/core/src/datayoga_core/blocks/relational/write/block.py b/core/src/datayoga_core/blocks/relational/write/block.py
@@ -179,10 +179,12 @@ def generate_upsert_stmt(self) -> Any:
                 relational_utils.construct_table_reference(self.tbl),
                 ", ".join([f"{sa.bindparam(column)}" for column in self.business_key_columns]),
                 ", ".join([f"{column}" for column in self.business_key_columns]),
-                " AND ".join([f'target."{column}" = source."{column}"' for column in self.business_key_columns]),
+                " AND ".join([f"target.{column} = source.{column}" for column in self.business_key_columns]),
+                # " AND ".join([f'target."{column}" = source."{column}"' for column in self.business_key_columns]),
                 ", ".join([f"{column}" for column in self.columns]),
                 ", ".join([f"{sa.bindparam(column)}" for column in self.columns]),
-                ", ".join([f'target."{column}" = {sa.bindparam(column)}' for column in self.mapping_columns])
+                ", ".join([f"target.{column} = {sa.bindparam(column)}" for column in self.mapping_columns])
+                # ", ".join([f'target."{column}" = {sa.bindparam(column)}' for column in self.mapping_columns])
             ))
 
     def execute(self, statement: Any, records: List[Dict[str, Any]]):