immediate return

PeerDB-io · Nov 21, 2023 · 39bdc9d · 39bdc9d
1 parent 8274773
commit 39bdc9d
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/flow/connectors/postgres/cdc.go b/flow/connectors/postgres/cdc.go
@@ -265,6 +265,12 @@ func (p *PostgresCDCSource) consumeStream(
 					req.FlowJobName,
 					len(localRecords),
 				)
+
+				if !p.commitLock {
+					// immediate return if we are not waiting for a commit
+					return nil
+				}
+
 				waitingForCommit = true
 			} else {
 				log.Infof("[%s] standby deadline reached, no records accumulated, continuing to wait",