fix: Use correct timezones for delete query for Snowflake Destination (#14097)

bbernays · web-flow · commit 91da6470f2ca · 2023-09-27T15:49:07.000Z
#### Summary

It seems by default Snowflake uses `America/Pacific` timezone or the current session timezone (if it was overridden via the connection string) when using the `timestamp_tz` by switching to  `timestamp_ntz` all timestamps will be in UTC
diff --git a/plugins/destination/snowflake/client/deletestale.go b/plugins/destination/snowflake/client/deletestale.go
@@ -18,7 +18,7 @@ func (c *Client) DeleteStale(ctx context.Context, msgs message.WriteDeleteStales
 		sb.WriteString(`"` + strings.ToUpper(schema.CqSourceNameColumn.Name) + `"`)
 		sb.WriteString(" = ? and \"")
 		sb.WriteString(strings.ToUpper(schema.CqSyncTimeColumn.Name))
-		sb.WriteString("\"::timestamp_tz < ?::timestamp_tz")
+		sb.WriteString("\"::timestamp_ntz < ?::timestamp_ntz")
 		sql := sb.String()
 		if _, err := c.db.ExecContext(ctx, sql, msg.SourceName, msg.SyncTime); err != nil {
 			return err
