From b79953f61ee3ad7531fc6985e2b0f65853f825d1 Mon Sep 17 00:00:00 2001 From: Kevin Biju Date: Tue, 9 Apr 2024 23:06:23 +0530 Subject: [PATCH] silly miss, no params --- flow/connectors/postgres/postgres.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flow/connectors/postgres/postgres.go b/flow/connectors/postgres/postgres.go index a8ea925dda..3494a64585 100644 --- a/flow/connectors/postgres/postgres.go +++ b/flow/connectors/postgres/postgres.go @@ -618,7 +618,7 @@ func (c *PostgresConnector) NormalizeRecords(ctx context.Context, req *model.Nor for _, destinationTableName := range destinationTableNames { normalizeStatements := normalizeStmtGen.generateNormalizeStatements(destinationTableName) for _, normalizeStatement := range normalizeStatements { - ct, err := normalizeRecordsTx.Exec(ctx, normalizeStatement) + ct, err := normalizeRecordsTx.Exec(ctx, normalizeStatement, normBatchID, req.SyncBatchID, destinationTableName) if err != nil { return nil, fmt.Errorf("error executing merge statements: %w", err) }