minor fixes pt.2

PeerDB-io · Jan 3, 2024 · 653da11 · 653da11
1 parent e6c03b0
commit 653da11
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/flow/connectors/postgres/postgres.go b/flow/connectors/postgres/postgres.go
@@ -468,7 +468,6 @@ func (c *PostgresConnector) NormalizeRecords(req *model.NormalizeRecordsRequest)
 		}
 		normalizeStatements := c.generateNormalizeStatements(destinationTableName, unchangedToastColsMap[destinationTableName],
 			rawTableIdentifier, supportsMerge, &peerdbCols)
-		fmt.Println(normalizeStatements)
 		for _, normalizeStatement := range normalizeStatements {
 			mergeStatementsBatch.Queue(normalizeStatement, batchIDs.NormalizeBatchID, batchIDs.SyncBatchID, destinationTableName).Exec(
 				func(ct pgconn.CommandTag) error {

diff --git a/flow/e2e/test_utils.go b/flow/e2e/test_utils.go
@@ -76,7 +76,7 @@ func SetupCDCFlowStatusQuery(env *testsuite.TestWorkflowEnvironment,
 				slog.Error(err.Error())
 			}
 
-			if state.CurrentFlowState == protos.FlowStatus_STATUS_RUNNING.Enum() {
+			if *state.CurrentFlowState == protos.FlowStatus_STATUS_RUNNING {
 				break
 			}
 		} else {