more logging, counting

PeerDB-io · Feb 15, 2024 · 44148af · 44148af
1 parent 3bc529b
commit 44148af
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/flow/connectors/postgres/cdc.go b/flow/connectors/postgres/cdc.go
@@ -170,10 +170,12 @@ func (p *PostgresCDCSource) PullRecords(ctx context.Context, req *model.PullReco
 	pkmRequiresResponse := false
 	waitingForCommit := false
 
+	iii := 0
 	for {
+		iii++
 		_, err := p.getCurrentLSN(ctx)
 		if err != nil {
-			return fmt.Errorf("!!! current LSN: %w", err)
+			return fmt.Errorf("!!! current LSN %d: %w", iii, err)
 		}
 
 		if pkmRequiresResponse {

diff --git a/flow/connectors/postgres/postgres.go b/flow/connectors/postgres/postgres.go
@@ -348,6 +348,11 @@ func (c *PostgresConnector) PullRecords(ctx context.Context, catalogPool *pgxpoo
 		return err
 	}
 
+	_, err = c.getCurrentLSN(ctx)
+	if err != nil {
+		return fmt.Errorf("=== current LSN: %w", err)
+	}
+
 	cdc, err := c.NewPostgresCDCSource(&PostgresCDCConfig{
 		SrcTableIDNameMapping:  req.SrcTableIDNameMapping,
 		Slot:                   slotName,