commit the tx

PeerDB-io · Nov 15, 2023 · 98bba14 · 98bba14
1 parent 755dacf
commit 98bba14
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/flow/connectors/snowflake/snowflake.go b/flow/connectors/snowflake/snowflake.go
@@ -1111,6 +1111,11 @@ func (c *SnowflakeConnector) generateAndExecuteMergeStatement(
 			destinationTableIdentifier, mergeStatement, err)
 	}
 
+	err = mergeTx.Commit()
+	if err != nil {
+		return 0, fmt.Errorf("unable to commit transaction for merge: %w", err)
+	}
+
 	endTime := time.Now()
 	log.Infof("[merge] merged records into %s, took: %d seconds",
 		destinationTableIdentifier, endTime.Sub(startTime)/time.Second)