more reduce logging

PeerDB-io · Dec 17, 2024 · 3292a4e · 3292a4e
1 parent e05c2a0
commit 3292a4e
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/flow/connectors/external_metadata/store.go b/flow/connectors/external_metadata/store.go
@@ -6,6 +6,7 @@ import (
 	"log/slog"
 	"time"
 
+	"github.com/jackc/pglogrepl"
 	"github.com/jackc/pgx/v5"
 	"github.com/jackc/pgx/v5/pgtype"
 	"github.com/jackc/pgx/v5/pgxpool"
@@ -135,7 +136,7 @@ func (p *PostgresMetadata) GetLastNormalizeBatchID(ctx context.Context, jobName
 }
 
 func (p *PostgresMetadata) SetLastOffset(ctx context.Context, jobName string, offset int64) error {
-	p.logger.Info("updating last offset", "offset", offset)
+	p.logger.Debug("updating last offset", slog.String("offset", pglogrepl.LSN(offset).String()))
 	_, err := p.pool.Exec(ctx, `
 		INSERT INTO `+lastSyncStateTableName+` (job_name, last_offset, sync_batch_id)
 		VALUES ($1, $2, $3)