PG Resync Query: Fix syntax (#2156)

Missing a space between words in the rename query
PeerDB-io · Oct 17, 2024 · 053f1e8 · 053f1e8
1 parent 43ccfe3
commit 053f1e8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flow/connectors/postgres/postgres.go b/flow/connectors/postgres/postgres.go
@@ -1389,7 +1389,7 @@ func (c *PostgresConnector) RenameTables(
 				c.logger.Info(fmt.Sprintf("handling soft-deletes for table '%s'...", dst))
 				_, err = c.execWithLoggingTx(ctx,
 					fmt.Sprintf(
-						"INSERT INTO %s(%s) SELECT %s,true AS %s FROM %s original_table"+
+						"INSERT INTO %s(%s) SELECT %s,true AS %s FROM %s original_table "+
 							"WHERE NOT EXISTS (SELECT 1 FROM %s resync_table WHERE %s)",
 						src, fmt.Sprintf("%s,%s", allCols, QuoteIdentifier(req.SoftDeleteColName)), allCols, req.SoftDeleteColName,
 						dst, src, pkeyColCompareStr), renameTablesTx)