fix more

PeerDB-io · Nov 16, 2023 · efb5dd4 · efb5dd4
1 parent 52257d6
commit efb5dd4
Showing 1 changed file with 4 additions and 6 deletions.
diff --git a/flow/connectors/postgres/cdc.go b/flow/connectors/postgres/cdc.go
@@ -235,12 +235,10 @@ func (p *PostgresCDCSource) consumeStream(
 			pkmRequiresResponse = false
 		}
 
-		if time.Now().After(nextStandbyMessageDeadline) {
-			if len(localRecords) <= 1 {
-				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)
-			}
+		if len(localRecords) <= 1 {
+			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)
 		}
 
 		if (len(localRecords) >= int(req.MaxBatchSize)) && !p.commitLock {