From 1acb5675f4c26614a890cd221af74bb9d52cefe0 Mon Sep 17 00:00:00 2001 From: "renovate[bot]" <29139614+renovate[bot]@users.noreply.github.com> Date: Mon, 18 May 2026 10:51:59 +0000 Subject: [PATCH] fix(deps): update module github.com/riverqueue/rivercontrib/otelriver to v0.8.0 --- go.mod | 4 ++-- go.sum | 2 ++ .../riverqueue/rivercontrib/otelriver/middleware.go | 8 ++++++++ vendor/modules.txt | 4 ++-- 4 files changed, 14 insertions(+), 4 deletions(-) diff --git a/go.mod b/go.mod index 218c0bbc..dc919730 100644 --- a/go.mod +++ b/go.mod @@ -40,7 +40,7 @@ require ( github.com/riverqueue/river v0.35.1 github.com/riverqueue/river/riverdriver/riverpgxv5 v0.35.1 github.com/riverqueue/river/rivertype v0.35.1 - github.com/riverqueue/rivercontrib/otelriver v0.7.0 + github.com/riverqueue/rivercontrib/otelriver v0.8.0 github.com/rodaine/table v1.3.1 github.com/sourcegraph/jsonrpc2 v0.2.1 github.com/spf13/cobra v1.10.2 @@ -58,6 +58,7 @@ require ( golang.org/x/crypto v0.51.0 golang.org/x/oauth2 v0.36.0 golang.org/x/sys v0.44.0 + golang.org/x/text v0.37.0 google.golang.org/grpc v1.81.0 google.golang.org/protobuf v1.36.12-0.20260120151049-f2248ac996af k8s.io/client-go v0.36.0 @@ -199,7 +200,6 @@ require ( golang.org/x/net v0.53.0 // indirect golang.org/x/sync v0.20.0 // indirect golang.org/x/term v0.43.0 // indirect - golang.org/x/text v0.37.0 // indirect golang.org/x/time v0.15.0 // indirect golang.org/x/tools v0.44.0 // indirect google.golang.org/genproto/googleapis/api v0.0.0-20260427160629-7cedc36a6bc4 // indirect diff --git a/go.sum b/go.sum index a0ad7aa5..022e7094 100644 --- a/go.sum +++ b/go.sum @@ -382,6 +382,8 @@ github.com/riverqueue/river/rivertype v0.35.1 h1:7SfjZ3Hkr7gRjItMHAUzJBAHIqx41yS github.com/riverqueue/river/rivertype v0.35.1/go.mod h1:D1Ad+EaZiaXbQbJcJcfeicXJMBKno0n6UcfKI5Q7DIQ= github.com/riverqueue/rivercontrib/otelriver v0.7.0 h1:zLjPf674dcGrz7OPG2JF5xea0fyitFax6Cc6q370Xzo= github.com/riverqueue/rivercontrib/otelriver v0.7.0/go.mod h1:MuyMZmYBz3JXC8ZLP0dH9IqXK95qRY6gCQSoJGh9h7E= +github.com/riverqueue/rivercontrib/otelriver v0.8.0 h1:zBFuoMhcGq0P1rrNl+kbxW6A2EI3/eRROAkY6bnNCZE= +github.com/riverqueue/rivercontrib/otelriver v0.8.0/go.mod h1:qwnMagI9IsFGEaKlp5oMecLGxE4byhOk8kqis7oeomo= github.com/robfig/cron/v3 v3.0.1 h1:WdRxkvbJztn8LMz/QEvLN5sBU+xKpSqwwUO1Pjr4qDs= github.com/robfig/cron/v3 v3.0.1/go.mod h1:eQICP3HwyT7UooqI/z+Ov+PtYAWygg1TEWWzGIFLtro= github.com/rodaine/table v1.3.1 h1:jBVgg1bEu5EzEdYSrwUUlQpayDtkvtTmgFS0FPAxOq8= diff --git a/vendor/github.com/riverqueue/rivercontrib/otelriver/middleware.go b/vendor/github.com/riverqueue/rivercontrib/otelriver/middleware.go index be7e10b3..e47a3fd8 100644 --- a/vendor/github.com/riverqueue/rivercontrib/otelriver/middleware.go +++ b/vendor/github.com/riverqueue/rivercontrib/otelriver/middleware.go @@ -211,10 +211,18 @@ func (m *Middleware) Work(ctx context.Context, job *rivertype.JobRow, doInner fu duration := m.durationInPreferredUnit(time.Since(begin)) if err != nil { + var batchResult interface { // To be superseded if riverbatch.MultiError is moved to rivertype. + ErrorsByID() map[int64]error + } + if errors.As(err, &batchResult) { + err = batchResult.ErrorsByID()[job.ID] + } + var ( cancelErr *river.JobCancelError snoozeErr *river.JobSnoozeError ) + switch { case errors.As(err, &cancelErr): attrs = append(attrs, attribute.Bool("cancel", true)) diff --git a/vendor/modules.txt b/vendor/modules.txt index c57c96ba..8dc76dc3 100644 --- a/vendor/modules.txt +++ b/vendor/modules.txt @@ -774,8 +774,8 @@ github.com/riverqueue/river/rivershared/util/valutil # github.com/riverqueue/river/rivertype v0.35.1 ## explicit; go 1.25.0 github.com/riverqueue/river/rivertype -# github.com/riverqueue/rivercontrib/otelriver v0.7.0 -## explicit; go 1.24.0 +# github.com/riverqueue/rivercontrib/otelriver v0.8.0 +## explicit; go 1.25.0 github.com/riverqueue/rivercontrib/otelriver # github.com/rodaine/table v1.3.1 ## explicit; go 1.21