From 8830802ca307a57e132e068911c68f7b110c8388 Mon Sep 17 00:00:00 2001 From: David Thorpe Date: Sat, 27 Jun 2026 11:27:33 +0200 Subject: [PATCH] Small pg fixes --- pgmanager/manager/metrics.go | 3 +-- pgqueue/manager/metrics.go | 1 + pgqueue/manager/run.go | 4 ++-- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/pgmanager/manager/metrics.go b/pgmanager/manager/metrics.go index 98d3345..c47de3a 100644 --- a/pgmanager/manager/metrics.go +++ b/pgmanager/manager/metrics.go @@ -5,9 +5,8 @@ import ( "strings" // Packages - otel "github.com/mutablelogic/go-client/pkg/otel" - "github.com/mutablelogic/go-pg" + pg "github.com/mutablelogic/go-pg" schema "github.com/mutablelogic/go-pg/pgmanager/schema" types "github.com/mutablelogic/go-server/pkg/types" attribute "go.opentelemetry.io/otel/attribute" diff --git a/pgqueue/manager/metrics.go b/pgqueue/manager/metrics.go index b03ea36..54df923 100644 --- a/pgqueue/manager/metrics.go +++ b/pgqueue/manager/metrics.go @@ -30,6 +30,7 @@ func (manager *Manager) registerMetrics() error { metric.WithAttributes( attribute.String("queue", status.Queue), attribute.String("status", status.Status), + attribute.String("worker", manager.opt.worker), ), ) } diff --git a/pgqueue/manager/run.go b/pgqueue/manager/run.go index dc27329..b6ba7df 100644 --- a/pgqueue/manager/run.go +++ b/pgqueue/manager/run.go @@ -182,7 +182,7 @@ func (manager *Manager) Run(ctx context.Context, log *slog.Logger) error { if result.Error != nil { log.ErrorContext(resultCtx, "RunQueueTask result failed", "queue", result.Queue, "task", result.Task.Id, "status", status, "error", result.Error.Error()) } else { - log.InfoContext(resultCtx, "RunQueueTask result", "queue", result.Queue, "task", result.Task.Id, "status", status, "result", result) + log.DebugContext(resultCtx, "RunQueueTask result", "queue", result.Queue, "task", result.Task.Id, "status", status, "result", result) } // A slot just freed up — immediately try to pick up another task. queueTimer.Reset(0) @@ -196,7 +196,7 @@ func (manager *Manager) Run(ctx context.Context, log *slog.Logger) error { if result.Error != nil { log.ErrorContext(resultCtx, "RunTickerTask result failed", "ticker", result.Ticker, "error", result.Error.Error()) } else if len(result.Result) > 0 && !bytes.Equal(result.Result, []byte("null")) { - log.InfoContext(resultCtx, "RunTickerTask result", "ticker", result.Ticker, "result", result) + log.DebugContext(resultCtx, "RunTickerTask result", "ticker", result.Ticker, "result", result) } } case <-timerC: