Add better logging to log the number of records (#1237)

PeerDB-io · Feb 9, 2024 · 81ae25d · 81ae25d
1 parent 094b69d
commit 81ae25d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/flow/connectors/postgres/cdc.go b/flow/connectors/postgres/cdc.go
@@ -225,7 +225,9 @@ func (p *PostgresCDCSource) consumeStream(
 	shutdown := utils.HeartbeatRoutine(p.ctx, func() string {
 		jobName := p.flowJobName
 		currRecords := cdcRecordsStorage.Len()
-		return fmt.Sprintf("pulling records for job - %s, currently have %d records", jobName, currRecords)
+		msg := fmt.Sprintf("pulling records for job - %s, currently have %d records", jobName, currRecords)
+		p.logger.Info(msg)
+		return msg
 	})
 	defer shutdown()