one more fix

PeerDB-io · Nov 17, 2023 · a93499b · a93499b
1 parent efb5dd4
commit a93499b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flow/connectors/postgres/cdc.go b/flow/connectors/postgres/cdc.go
@@ -235,7 +235,7 @@ func (p *PostgresCDCSource) consumeStream(
 			pkmRequiresResponse = false
 		}
 
-		if len(localRecords) <= 1 {
+		if len(localRecords) == 0 {
 			log.Infof("pushing the standby deadline to %s", time.Now().Add(standbyMessageTimeout))
 			log.Infof("num records accumulated: %d", len(localRecords))
 			nextStandbyMessageDeadline = time.Now().Add(standbyMessageTimeout)