Skip to content

Commit

Permalink
Update flow/connectors/postgres/client.go
Browse files Browse the repository at this point in the history
Co-authored-by: Philip Dubé <[email protected]>
  • Loading branch information
heavycrystal and serprex authored Dec 19, 2024
1 parent 2a551ef commit d3a066c
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion flow/connectors/postgres/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -660,7 +660,7 @@ func (c *PostgresConnector) getCurrentLSN(ctx context.Context) (pglogrepl.LSN, e
return 0, fmt.Errorf("error while running query for current LSN: %w", err)
}
if !result.Valid || result.String == "" {
return 0, fmt.Errorf("error while getting current LSN: query result is not valid text: %s", result.String)
return 0, errors.New("error while getting current LSN: no LSN available")
}
lsn, err := pglogrepl.ParseLSN(result.String)
if err != nil {
Expand Down

0 comments on commit d3a066c

Please sign in to comment.