add useful logging

PeerDB-io · Feb 8, 2024 · 9470a0e · 9470a0e
1 parent 863452e
commit 9470a0e
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/flow/connectors/postgres/cdc.go b/flow/connectors/postgres/cdc.go
@@ -246,6 +246,7 @@ func (p *PostgresCDCSource) consumeStream(
 	shutdown := utils.HeartbeatRoutine(p.ctx, func() string {
 		jobName := p.flowJobName
 		currRecords := cdcRecordsStorage.Len()
+		p.logger.Info(fmt.Sprintf("pulling records for job - %s, currently have %d records", jobName, currRecords))
 		return fmt.Sprintf("pulling records for job - %s, currently have %d records", jobName, currRecords)
 	})
 	defer shutdown()