modify even on delete

PeerDB-io · Nov 14, 2023 · 6a892ce · 6a892ce
1 parent 57d52d0
commit 6a892ce
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/flow/connectors/snowflake/snowflake.go b/flow/connectors/snowflake/snowflake.go
@@ -1035,6 +1035,9 @@ func (c *SnowflakeConnector) generateAndExecuteMergeStatement(
 	if normalizeReq.SoftDelete {
 		colName := normalizeReq.SoftDeleteColName
 		deletePart = fmt.Sprintf("UPDATE SET %s = TRUE", colName)
+		if normalizeReq.SyncedAtColName != "" {
+			deletePart = fmt.Sprintf("%s, %s = CURRENT_TIMESTAMP", deletePart, normalizeReq.SyncedAtColName)
+		}
 	}
 
 	mergeStatement := fmt.Sprintf(mergeStatementSQL, destinationTableIdentifier, toVariantColumnName,