diff --git a/.golangci.yaml b/.golangci.yaml
index 5c878d7..acef8fd 100644
--- a/.golangci.yaml
+++ b/.golangci.yaml
@@ -42,19 +42,22 @@ run:
   # Define the Go version limit.
   # Mainly related to generics support since go1.18.
   # Default: use Go version from the go.mod file, fallback on the env var `GOVERSION`, fallback on 1.17
-  go: "1.26.2"
+  go: "1.26.3"
 
 linters:
   # Enable specific linter
   # https://golangci-lint.run/usage/linters/#enabled-by-default
   default: all
   enable:
+    - gomodguard_v2
     - wsl_v5
   disable:
     - depguard
     - embeddedstructfieldcheck
     - exhaustruct
+    - goconst # re-enable it
     - gomoddirectives
+    - gomodguard
     - ireturn
     - lll
     - nonamedreturns
diff --git a/.pre-commit/golangci-lint-hook b/.pre-commit/golangci-lint-hook
index 86718b2..2083d43 100755
--- a/.pre-commit/golangci-lint-hook
+++ b/.pre-commit/golangci-lint-hook
@@ -23,7 +23,7 @@ if [[ -f "${ROOT_DIR}/.project-settings.env" ]]; then
 	# shellcheck disable=SC1090
 	source "${ROOT_DIR}/.project-settings.env"
 fi
-GOLANGCI_LINT_VERSION="${GOLANGCI_LINT_VERSION:-v2.11.4}"
+GOLANGCI_LINT_VERSION="${GOLANGCI_LINT_VERSION:-v2.12.2}"
 
 # #######################################
 # Install dependencies to run the pre-commit hook
diff --git a/.pre-commit/unit-test-hook b/.pre-commit/unit-test-hook
index 97057e8..906498a 100755
--- a/.pre-commit/unit-test-hook
+++ b/.pre-commit/unit-test-hook
@@ -21,7 +21,7 @@ hook() {
 	local root_dir
 	root_dir=$(git rev-parse --show-toplevel)
 
-	local toolchain_version="1.26.2"
+	local toolchain_version="1.26.3"
 	if [[ -f "${root_dir}/.project-settings.env" ]]; then
 		# shellcheck disable=SC1090
 		source "${root_dir}/.project-settings.env"
diff --git a/.project-settings.env b/.project-settings.env
index 9214d9a..5441bca 100644
--- a/.project-settings.env
+++ b/.project-settings.env
@@ -1,5 +1,5 @@
-GOLANGCI_LINT_VERSION=v2.11.4
-BUF_VERSION=v1.68.2
-GO_VERSION=1.26.2
+GOLANGCI_LINT_VERSION=v2.12.2
+BUF_VERSION=v1.69.0
+GO_VERSION=1.26.3
 GCI_PREFIX=github.com/hyp3rd/go-worker
 PROTO_ENABLED=true
diff --git a/.vscode/settings.json b/.vscode/settings.json
index 83accbf..15f7f88 100644
--- a/.vscode/settings.json
+++ b/.vscode/settings.json
@@ -2,6 +2,5 @@
   "yaml.schemas": {
     "https://golangci-lint.run/jsonschema/golangci.jsonschema.json": "file:///Users/dy14uc/Developer/github.com/hyp3rd/go-worker/.golangci.yaml"
   },
-  "snyk.advanced.organization": "e3a23328-9b6e-43a2-acb5-e23bc7cfc9dc",
   "snyk.advanced.autoSelectOrganization": true
 }
diff --git a/Dockerfile b/Dockerfile
index 06d8b80..3a990a2 100644
--- a/Dockerfile
+++ b/Dockerfile
@@ -1,5 +1,5 @@
 # syntax=docker/dockerfile:1
-ARG GO_VERSION=1.26.2
+ARG GO_VERSION=1.26.3
 FROM --platform=$BUILDPLATFORM golang:${GO_VERSION}-alpine AS builder
 
 WORKDIR /src
diff --git a/Dockerfile.worker b/Dockerfile.worker
index ac30dd6..3a95e99 100644
--- a/Dockerfile.worker
+++ b/Dockerfile.worker
@@ -1,5 +1,5 @@
 # syntax=docker/dockerfile:1
-ARG GO_VERSION=1.26.2
+ARG GO_VERSION=1.26.3
 FROM --platform=$BUILDPLATFORM golang:${GO_VERSION}-alpine AS builder
 
 WORKDIR /src
diff --git a/Makefile b/Makefile
index f99c543..d492560 100644
--- a/Makefile
+++ b/Makefile
@@ -1,9 +1,9 @@
 include .project-settings.env
 
 REPO_ROOT = $(shell git rev-parse --show-toplevel)
-GOLANGCI_LINT_VERSION ?= v2.11.4
-BUF_VERSION ?= v1.68.2
-GO_VERSION ?= 1.26.2
+GOLANGCI_LINT_VERSION ?= v2.12.2
+BUF_VERSION ?= v1.69.0
+GO_VERSION ?= 1.26.3
 GCI_PREFIX ?= github.com/hyp3rd/go-worker
 PROTO_ENABLED ?= true
 BENCHTIME ?= 1s
diff --git a/go.mod b/go.mod
index 39fc4ee..78df140 100644
--- a/go.mod
+++ b/go.mod
@@ -1,19 +1,19 @@
 module github.com/hyp3rd/go-worker
 
-go 1.26.2
+go 1.26.3
 
 require (
 	github.com/goccy/go-json v0.10.6
 	github.com/google/uuid v1.6.0
 	github.com/hyp3rd/cron/v4 v4.0.1
-	github.com/hyp3rd/ewrap v1.4.0
-	github.com/hyp3rd/sectools v1.2.5
+	github.com/hyp3rd/ewrap v1.5.0
+	github.com/hyp3rd/sectools v1.2.6
 	github.com/redis/rueidis v1.0.74
 	github.com/spf13/cobra v1.10.2
 	go.opentelemetry.io/otel/metric v1.43.0
 	go.opentelemetry.io/otel/sdk/metric v1.43.0
 	golang.org/x/time v0.15.0
-	google.golang.org/grpc v1.80.0
+	google.golang.org/grpc v1.81.0
 	google.golang.org/protobuf v1.36.11
 	gopkg.in/yaml.v3 v3.0.1
 )
@@ -29,8 +29,8 @@ require (
 	go.opentelemetry.io/otel v1.43.0 // indirect
 	go.opentelemetry.io/otel/sdk v1.43.0 // indirect
 	go.opentelemetry.io/otel/trace v1.43.0 // indirect
-	golang.org/x/net v0.53.0 // indirect
-	golang.org/x/sys v0.43.0 // indirect
-	golang.org/x/text v0.36.0 // indirect
-	google.golang.org/genproto/googleapis/rpc v0.0.0-20260414002931-afd174a4e478 // indirect
+	golang.org/x/net v0.54.0 // indirect
+	golang.org/x/sys v0.44.0 // indirect
+	golang.org/x/text v0.37.0 // indirect
+	google.golang.org/genproto/googleapis/rpc v0.0.0-20260504160031-60b97b32f348 // indirect
 )
diff --git a/go.sum b/go.sum
index 510155a..08ef99b 100644
--- a/go.sum
+++ b/go.sum
@@ -18,12 +18,12 @@ github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
 github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/hyp3rd/cron/v4 v4.0.1 h1:QuQ9a7+kCat+xRbssLt+ubibAXLgww0+T1J8lTy0Y48=
 github.com/hyp3rd/cron/v4 v4.0.1/go.mod h1:4TQSY8fjNp05ajGxS2jFNdsHxBLAFk91snCRjW7z1v8=
-github.com/hyp3rd/ewrap v1.4.0 h1:RyxyYKDP8HLVDreWw+g89yTZfJjTNRcmrP3tiKQjZK4=
-github.com/hyp3rd/ewrap v1.4.0/go.mod h1:ob+oREpgZ9Bonq5C1tViaqBtWmh1H5EFWc9Bfn1lPB0=
+github.com/hyp3rd/ewrap v1.5.0 h1:jXNEO1u6IIXGMg7DktAk3wXheGYF5tAxB7YhHW4lIDw=
+github.com/hyp3rd/ewrap v1.5.0/go.mod h1:N3C08pcvWgJxXIzn3GqWYQhOh7Yvy5je7HoNTy4qlLI=
 github.com/hyp3rd/hyperlogger v0.1.8 h1:/C6f3rbn8RqTomR5hqrN9c6iUycQE7CjessR5IQ/m90=
 github.com/hyp3rd/hyperlogger v0.1.8/go.mod h1:lDnNfQdazN2cbbvyLcFKkAsxLbLd/Mknf2dUfwPUhEY=
-github.com/hyp3rd/sectools v1.2.5 h1:i3uyCA5jElfMwYPe0YQvPyDMSJIlKFMTgaqjsWd53ok=
-github.com/hyp3rd/sectools v1.2.5/go.mod h1:6olmYYaZFgHz6fLgv/XZf/kePquYUWIyfC6TeyJvWXg=
+github.com/hyp3rd/sectools v1.2.6 h1:WCrBOazUmZUSHHw34zxK41m5arK+GJ4P9nX/ZFzUc6U=
+github.com/hyp3rd/sectools v1.2.6/go.mod h1:qCk5b23hquPRpe/Bi8/Kavh63nFzQ6ad8GSYW1t2h4g=
 github.com/inconshreveable/mousetrap v1.1.0 h1:wN+x4NVGpMsO7ErUn/mUI3vEoE6Jt13X2s0bqwp9tc8=
 github.com/inconshreveable/mousetrap v1.1.0/go.mod h1:vpF70FUmC8bwa3OWnCshd2FqLfsEA9PFc4w1p2J65bw=
 github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE=
@@ -44,8 +44,6 @@ github.com/spf13/cobra v1.10.2/go.mod h1:7C1pvHqHw5A4vrJfjNwvOdzYu0Gml16OCs2GRiT
 github.com/spf13/pflag v1.0.9/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg=
 github.com/spf13/pflag v1.0.10 h1:4EBh2KAYBwaONj6b2Ye1GiHfwjqyROoF4RwYO+vPwFk=
 github.com/spf13/pflag v1.0.10/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg=
-github.com/stretchr/objx v0.5.2 h1:xuMeJ0Sdp5ZMRXx/aWO6RZxdr3beISkG5/G/aIRr3pY=
-github.com/stretchr/objx v0.5.2/go.mod h1:FRsXN1f5AsAjCGJKqEizvkpNtU+EGNCLh3NxZ/8L+MA=
 github.com/stretchr/testify v1.11.1 h1:7s2iGBzp5EwR7/aIZr8ao5+dra3wiQyKjjFuvgVKu7U=
 github.com/stretchr/testify v1.11.1/go.mod h1:wZwfW3scLgRK+23gO65QZefKpKQRnfz6sD981Nm4B6U=
 go.opentelemetry.io/auto/sdk v1.2.1 h1:jXsnJ4Lmnqd11kwkBV2LgLoFMZKizbCi5fNZ/ipaZ64=
@@ -62,20 +60,20 @@ go.opentelemetry.io/otel/trace v1.43.0 h1:BkNrHpup+4k4w+ZZ86CZoHHEkohws8AY+WTX09
 go.opentelemetry.io/otel/trace v1.43.0/go.mod h1:/QJhyVBUUswCphDVxq+8mld+AvhXZLhe+8WVFxiFff0=
 go.yaml.in/yaml/v3 v3.0.4 h1:tfq32ie2Jv2UxXFdLJdh3jXuOzWiL1fo0bu/FbuKpbc=
 go.yaml.in/yaml/v3 v3.0.4/go.mod h1:DhzuOOF2ATzADvBadXxruRBLzYTpT36CKvDb3+aBEFg=
-golang.org/x/net v0.53.0 h1:d+qAbo5L0orcWAr0a9JweQpjXF19LMXJE8Ey7hwOdUA=
-golang.org/x/net v0.53.0/go.mod h1:JvMuJH7rrdiCfbeHoo3fCQU24Lf5JJwT9W3sJFulfgs=
-golang.org/x/sys v0.43.0 h1:Rlag2XtaFTxp19wS8MXlJwTvoh8ArU6ezoyFsMyCTNI=
-golang.org/x/sys v0.43.0/go.mod h1:4GL1E5IUh+htKOUEOaiffhrAeqysfVGipDYzABqnCmw=
-golang.org/x/text v0.36.0 h1:JfKh3XmcRPqZPKevfXVpI1wXPTqbkE5f7JA92a55Yxg=
-golang.org/x/text v0.36.0/go.mod h1:NIdBknypM8iqVmPiuco0Dh6P5Jcdk8lJL0CUebqK164=
+golang.org/x/net v0.54.0 h1:2zJIZAxAHV/OHCDTCOHAYehQzLfSXuf/5SoL/Dv6w/w=
+golang.org/x/net v0.54.0/go.mod h1:Sj4oj8jK6XmHpBZU/zWHw3BV3abl4Kvi+Ut7cQcY+cQ=
+golang.org/x/sys v0.44.0 h1:ildZl3J4uzeKP07r2F++Op7E9B29JRUy+a27EibtBTQ=
+golang.org/x/sys v0.44.0/go.mod h1:4GL1E5IUh+htKOUEOaiffhrAeqysfVGipDYzABqnCmw=
+golang.org/x/text v0.37.0 h1:Cqjiwd9eSg8e0QAkyCaQTNHFIIzWtidPahFWR83rTrc=
+golang.org/x/text v0.37.0/go.mod h1:a5sjxXGs9hsn/AJVwuElvCAo9v8QYLzvavO5z2PiM38=
 golang.org/x/time v0.15.0 h1:bbrp8t3bGUeFOx08pvsMYRTCVSMk89u4tKbNOZbp88U=
 golang.org/x/time v0.15.0/go.mod h1:Y4YMaQmXwGQZoFaVFk4YpCt4FLQMYKZe9oeV/f4MSno=
 gonum.org/v1/gonum v0.17.0 h1:VbpOemQlsSMrYmn7T2OUvQ4dqxQXU+ouZFQsZOx50z4=
 gonum.org/v1/gonum v0.17.0/go.mod h1:El3tOrEuMpv2UdMrbNlKEh9vd86bmQ6vqIcDwxEOc1E=
-google.golang.org/genproto/googleapis/rpc v0.0.0-20260414002931-afd174a4e478 h1:RmoJA1ujG+/lRGNfUnOMfhCy5EipVMyvUE+KNbPbTlw=
-google.golang.org/genproto/googleapis/rpc v0.0.0-20260414002931-afd174a4e478/go.mod h1:4Hqkh8ycfw05ld/3BWL7rJOSfebL2Q+DVDeRgYgxUU8=
-google.golang.org/grpc v1.80.0 h1:Xr6m2WmWZLETvUNvIUmeD5OAagMw3FiKmMlTdViWsHM=
-google.golang.org/grpc v1.80.0/go.mod h1:ho/dLnxwi3EDJA4Zghp7k2Ec1+c2jqup0bFkw07bwF4=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20260504160031-60b97b32f348 h1:pfIbyB44sWzHiCpRqIen67ZQnVXSfIxWrqUMk1qwODE=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20260504160031-60b97b32f348/go.mod h1:4Hqkh8ycfw05ld/3BWL7rJOSfebL2Q+DVDeRgYgxUU8=
+google.golang.org/grpc v1.81.0 h1:W3G9N3KQf3BU+YuCtGKJk0CmxQNbAISICD/9AORxLIw=
+google.golang.org/grpc v1.81.0/go.mod h1:xGH9GfzOyMTGIOXBJmXt+BX/V0kcdQbdcuwQ/zNw42I=
 google.golang.org/protobuf v1.36.11 h1:fV6ZwhNocDyBLK0dj+fg8ektcVegBBuEolpbTQyBNVE=
 google.golang.org/protobuf v1.36.11/go.mod h1:HTf+CrKn2C3g5S8VImy6tdcUvCska2kB7j23XfzDpco=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
diff --git a/pkg/worker/v1/admin.pb.go b/pkg/worker/v1/admin.pb.go
index 50d5469..8b7c39c 100644
--- a/pkg/worker/v1/admin.pb.go
+++ b/pkg/worker/v1/admin.pb.go
@@ -7,12 +7,11 @@
 package workerpb
 
 import (
+	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
+	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
 	reflect "reflect"
 	sync "sync"
 	unsafe "unsafe"
-
-	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
-	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
 )
 
 const (
@@ -4153,85 +4152,82 @@ func file_worker_v1_admin_proto_rawDescGZIP() []byte {
 	return file_worker_v1_admin_proto_rawDescData
 }
 
-var (
-	file_worker_v1_admin_proto_msgTypes = make([]protoimpl.MessageInfo, 73)
-	file_worker_v1_admin_proto_goTypes  = []any{
-		(*GetOverviewRequest)(nil),            // 0: worker.v1.GetOverviewRequest
-		(*OverviewStats)(nil),                 // 1: worker.v1.OverviewStats
-		(*CoordinationStatus)(nil),            // 2: worker.v1.CoordinationStatus
-		(*AdminActionCounters)(nil),           // 3: worker.v1.AdminActionCounters
-		(*GetOverviewResponse)(nil),           // 4: worker.v1.GetOverviewResponse
-		(*GetHealthRequest)(nil),              // 5: worker.v1.GetHealthRequest
-		(*GetHealthResponse)(nil),             // 6: worker.v1.GetHealthResponse
-		(*QueueSummary)(nil),                  // 7: worker.v1.QueueSummary
-		(*ListQueuesRequest)(nil),             // 8: worker.v1.ListQueuesRequest
-		(*ListQueuesResponse)(nil),            // 9: worker.v1.ListQueuesResponse
-		(*GetQueueRequest)(nil),               // 10: worker.v1.GetQueueRequest
-		(*GetQueueResponse)(nil),              // 11: worker.v1.GetQueueResponse
-		(*UpdateQueueWeightRequest)(nil),      // 12: worker.v1.UpdateQueueWeightRequest
-		(*UpdateQueueWeightResponse)(nil),     // 13: worker.v1.UpdateQueueWeightResponse
-		(*ResetQueueWeightRequest)(nil),       // 14: worker.v1.ResetQueueWeightRequest
-		(*ResetQueueWeightResponse)(nil),      // 15: worker.v1.ResetQueueWeightResponse
-		(*PauseQueueRequest)(nil),             // 16: worker.v1.PauseQueueRequest
-		(*PauseQueueResponse)(nil),            // 17: worker.v1.PauseQueueResponse
-		(*ScheduleEntry)(nil),                 // 18: worker.v1.ScheduleEntry
-		(*ScheduleFactory)(nil),               // 19: worker.v1.ScheduleFactory
-		(*ScheduleEvent)(nil),                 // 20: worker.v1.ScheduleEvent
-		(*ListScheduleFactoriesRequest)(nil),  // 21: worker.v1.ListScheduleFactoriesRequest
-		(*ListScheduleFactoriesResponse)(nil), // 22: worker.v1.ListScheduleFactoriesResponse
-		(*ListScheduleEventsRequest)(nil),     // 23: worker.v1.ListScheduleEventsRequest
-		(*ListScheduleEventsResponse)(nil),    // 24: worker.v1.ListScheduleEventsResponse
-		(*ListSchedulesRequest)(nil),          // 25: worker.v1.ListSchedulesRequest
-		(*ListSchedulesResponse)(nil),         // 26: worker.v1.ListSchedulesResponse
-		(*CreateScheduleRequest)(nil),         // 27: worker.v1.CreateScheduleRequest
-		(*CreateScheduleResponse)(nil),        // 28: worker.v1.CreateScheduleResponse
-		(*DeleteScheduleRequest)(nil),         // 29: worker.v1.DeleteScheduleRequest
-		(*DeleteScheduleResponse)(nil),        // 30: worker.v1.DeleteScheduleResponse
-		(*PauseScheduleRequest)(nil),          // 31: worker.v1.PauseScheduleRequest
-		(*PauseScheduleResponse)(nil),         // 32: worker.v1.PauseScheduleResponse
-		(*RunScheduleRequest)(nil),            // 33: worker.v1.RunScheduleRequest
-		(*RunScheduleResponse)(nil),           // 34: worker.v1.RunScheduleResponse
-		(*PauseSchedulesRequest)(nil),         // 35: worker.v1.PauseSchedulesRequest
-		(*PauseSchedulesResponse)(nil),        // 36: worker.v1.PauseSchedulesResponse
-		(*JobSpec)(nil),                       // 37: worker.v1.JobSpec
-		(*Job)(nil),                           // 38: worker.v1.Job
-		(*JobEvent)(nil),                      // 39: worker.v1.JobEvent
-		(*ListJobsRequest)(nil),               // 40: worker.v1.ListJobsRequest
-		(*ListJobsResponse)(nil),              // 41: worker.v1.ListJobsResponse
-		(*ListJobEventsRequest)(nil),          // 42: worker.v1.ListJobEventsRequest
-		(*ListJobEventsResponse)(nil),         // 43: worker.v1.ListJobEventsResponse
-		(*AuditEvent)(nil),                    // 44: worker.v1.AuditEvent
-		(*ListAuditEventsRequest)(nil),        // 45: worker.v1.ListAuditEventsRequest
-		(*ListAuditEventsResponse)(nil),       // 46: worker.v1.ListAuditEventsResponse
-		(*GetJobRequest)(nil),                 // 47: worker.v1.GetJobRequest
-		(*GetJobResponse)(nil),                // 48: worker.v1.GetJobResponse
-		(*UpsertJobRequest)(nil),              // 49: worker.v1.UpsertJobRequest
-		(*UpsertJobResponse)(nil),             // 50: worker.v1.UpsertJobResponse
-		(*DeleteJobRequest)(nil),              // 51: worker.v1.DeleteJobRequest
-		(*DeleteJobResponse)(nil),             // 52: worker.v1.DeleteJobResponse
-		(*RunJobRequest)(nil),                 // 53: worker.v1.RunJobRequest
-		(*RunJobResponse)(nil),                // 54: worker.v1.RunJobResponse
-		(*DLQEntry)(nil),                      // 55: worker.v1.DLQEntry
-		(*DLQEntryDetail)(nil),                // 56: worker.v1.DLQEntryDetail
-		(*GetDLQEntryRequest)(nil),            // 57: worker.v1.GetDLQEntryRequest
-		(*GetDLQEntryResponse)(nil),           // 58: worker.v1.GetDLQEntryResponse
-		(*ListDLQRequest)(nil),                // 59: worker.v1.ListDLQRequest
-		(*ListDLQResponse)(nil),               // 60: worker.v1.ListDLQResponse
-		(*PauseDequeueRequest)(nil),           // 61: worker.v1.PauseDequeueRequest
-		(*PauseDequeueResponse)(nil),          // 62: worker.v1.PauseDequeueResponse
-		(*ResumeDequeueRequest)(nil),          // 63: worker.v1.ResumeDequeueRequest
-		(*ResumeDequeueResponse)(nil),         // 64: worker.v1.ResumeDequeueResponse
-		(*ReplayDLQRequest)(nil),              // 65: worker.v1.ReplayDLQRequest
-		(*ReplayDLQResponse)(nil),             // 66: worker.v1.ReplayDLQResponse
-		(*ReplayDLQByIDRequest)(nil),          // 67: worker.v1.ReplayDLQByIDRequest
-		(*ReplayDLQByIDResponse)(nil),         // 68: worker.v1.ReplayDLQByIDResponse
-		nil,                                   // 69: worker.v1.ScheduleEvent.MetadataEntry
-		nil,                                   // 70: worker.v1.JobEvent.MetadataEntry
-		nil,                                   // 71: worker.v1.AuditEvent.MetadataEntry
-		nil,                                   // 72: worker.v1.DLQEntryDetail.MetadataEntry
-	}
-)
-
+var file_worker_v1_admin_proto_msgTypes = make([]protoimpl.MessageInfo, 73)
+var file_worker_v1_admin_proto_goTypes = []any{
+	(*GetOverviewRequest)(nil),            // 0: worker.v1.GetOverviewRequest
+	(*OverviewStats)(nil),                 // 1: worker.v1.OverviewStats
+	(*CoordinationStatus)(nil),            // 2: worker.v1.CoordinationStatus
+	(*AdminActionCounters)(nil),           // 3: worker.v1.AdminActionCounters
+	(*GetOverviewResponse)(nil),           // 4: worker.v1.GetOverviewResponse
+	(*GetHealthRequest)(nil),              // 5: worker.v1.GetHealthRequest
+	(*GetHealthResponse)(nil),             // 6: worker.v1.GetHealthResponse
+	(*QueueSummary)(nil),                  // 7: worker.v1.QueueSummary
+	(*ListQueuesRequest)(nil),             // 8: worker.v1.ListQueuesRequest
+	(*ListQueuesResponse)(nil),            // 9: worker.v1.ListQueuesResponse
+	(*GetQueueRequest)(nil),               // 10: worker.v1.GetQueueRequest
+	(*GetQueueResponse)(nil),              // 11: worker.v1.GetQueueResponse
+	(*UpdateQueueWeightRequest)(nil),      // 12: worker.v1.UpdateQueueWeightRequest
+	(*UpdateQueueWeightResponse)(nil),     // 13: worker.v1.UpdateQueueWeightResponse
+	(*ResetQueueWeightRequest)(nil),       // 14: worker.v1.ResetQueueWeightRequest
+	(*ResetQueueWeightResponse)(nil),      // 15: worker.v1.ResetQueueWeightResponse
+	(*PauseQueueRequest)(nil),             // 16: worker.v1.PauseQueueRequest
+	(*PauseQueueResponse)(nil),            // 17: worker.v1.PauseQueueResponse
+	(*ScheduleEntry)(nil),                 // 18: worker.v1.ScheduleEntry
+	(*ScheduleFactory)(nil),               // 19: worker.v1.ScheduleFactory
+	(*ScheduleEvent)(nil),                 // 20: worker.v1.ScheduleEvent
+	(*ListScheduleFactoriesRequest)(nil),  // 21: worker.v1.ListScheduleFactoriesRequest
+	(*ListScheduleFactoriesResponse)(nil), // 22: worker.v1.ListScheduleFactoriesResponse
+	(*ListScheduleEventsRequest)(nil),     // 23: worker.v1.ListScheduleEventsRequest
+	(*ListScheduleEventsResponse)(nil),    // 24: worker.v1.ListScheduleEventsResponse
+	(*ListSchedulesRequest)(nil),          // 25: worker.v1.ListSchedulesRequest
+	(*ListSchedulesResponse)(nil),         // 26: worker.v1.ListSchedulesResponse
+	(*CreateScheduleRequest)(nil),         // 27: worker.v1.CreateScheduleRequest
+	(*CreateScheduleResponse)(nil),        // 28: worker.v1.CreateScheduleResponse
+	(*DeleteScheduleRequest)(nil),         // 29: worker.v1.DeleteScheduleRequest
+	(*DeleteScheduleResponse)(nil),        // 30: worker.v1.DeleteScheduleResponse
+	(*PauseScheduleRequest)(nil),          // 31: worker.v1.PauseScheduleRequest
+	(*PauseScheduleResponse)(nil),         // 32: worker.v1.PauseScheduleResponse
+	(*RunScheduleRequest)(nil),            // 33: worker.v1.RunScheduleRequest
+	(*RunScheduleResponse)(nil),           // 34: worker.v1.RunScheduleResponse
+	(*PauseSchedulesRequest)(nil),         // 35: worker.v1.PauseSchedulesRequest
+	(*PauseSchedulesResponse)(nil),        // 36: worker.v1.PauseSchedulesResponse
+	(*JobSpec)(nil),                       // 37: worker.v1.JobSpec
+	(*Job)(nil),                           // 38: worker.v1.Job
+	(*JobEvent)(nil),                      // 39: worker.v1.JobEvent
+	(*ListJobsRequest)(nil),               // 40: worker.v1.ListJobsRequest
+	(*ListJobsResponse)(nil),              // 41: worker.v1.ListJobsResponse
+	(*ListJobEventsRequest)(nil),          // 42: worker.v1.ListJobEventsRequest
+	(*ListJobEventsResponse)(nil),         // 43: worker.v1.ListJobEventsResponse
+	(*AuditEvent)(nil),                    // 44: worker.v1.AuditEvent
+	(*ListAuditEventsRequest)(nil),        // 45: worker.v1.ListAuditEventsRequest
+	(*ListAuditEventsResponse)(nil),       // 46: worker.v1.ListAuditEventsResponse
+	(*GetJobRequest)(nil),                 // 47: worker.v1.GetJobRequest
+	(*GetJobResponse)(nil),                // 48: worker.v1.GetJobResponse
+	(*UpsertJobRequest)(nil),              // 49: worker.v1.UpsertJobRequest
+	(*UpsertJobResponse)(nil),             // 50: worker.v1.UpsertJobResponse
+	(*DeleteJobRequest)(nil),              // 51: worker.v1.DeleteJobRequest
+	(*DeleteJobResponse)(nil),             // 52: worker.v1.DeleteJobResponse
+	(*RunJobRequest)(nil),                 // 53: worker.v1.RunJobRequest
+	(*RunJobResponse)(nil),                // 54: worker.v1.RunJobResponse
+	(*DLQEntry)(nil),                      // 55: worker.v1.DLQEntry
+	(*DLQEntryDetail)(nil),                // 56: worker.v1.DLQEntryDetail
+	(*GetDLQEntryRequest)(nil),            // 57: worker.v1.GetDLQEntryRequest
+	(*GetDLQEntryResponse)(nil),           // 58: worker.v1.GetDLQEntryResponse
+	(*ListDLQRequest)(nil),                // 59: worker.v1.ListDLQRequest
+	(*ListDLQResponse)(nil),               // 60: worker.v1.ListDLQResponse
+	(*PauseDequeueRequest)(nil),           // 61: worker.v1.PauseDequeueRequest
+	(*PauseDequeueResponse)(nil),          // 62: worker.v1.PauseDequeueResponse
+	(*ResumeDequeueRequest)(nil),          // 63: worker.v1.ResumeDequeueRequest
+	(*ResumeDequeueResponse)(nil),         // 64: worker.v1.ResumeDequeueResponse
+	(*ReplayDLQRequest)(nil),              // 65: worker.v1.ReplayDLQRequest
+	(*ReplayDLQResponse)(nil),             // 66: worker.v1.ReplayDLQResponse
+	(*ReplayDLQByIDRequest)(nil),          // 67: worker.v1.ReplayDLQByIDRequest
+	(*ReplayDLQByIDResponse)(nil),         // 68: worker.v1.ReplayDLQByIDResponse
+	nil,                                   // 69: worker.v1.ScheduleEvent.MetadataEntry
+	nil,                                   // 70: worker.v1.JobEvent.MetadataEntry
+	nil,                                   // 71: worker.v1.AuditEvent.MetadataEntry
+	nil,                                   // 72: worker.v1.DLQEntryDetail.MetadataEntry
+}
 var file_worker_v1_admin_proto_depIdxs = []int32{
 	1,  // 0: worker.v1.GetOverviewResponse.stats:type_name -> worker.v1.OverviewStats
 	2,  // 1: worker.v1.GetOverviewResponse.coordination:type_name -> worker.v1.CoordinationStatus
diff --git a/pkg/worker/v1/admin_grpc.pb.go b/pkg/worker/v1/admin_grpc.pb.go
index 41ea594..ede0bbb 100644
--- a/pkg/worker/v1/admin_grpc.pb.go
+++ b/pkg/worker/v1/admin_grpc.pb.go
@@ -8,7 +8,6 @@ package workerpb
 
 import (
 	context "context"
-
 	grpc "google.golang.org/grpc"
 	codes "google.golang.org/grpc/codes"
 	status "google.golang.org/grpc/status"
@@ -416,111 +415,84 @@ type UnimplementedAdminServiceServer struct{}
 func (UnimplementedAdminServiceServer) GetHealth(context.Context, *GetHealthRequest) (*GetHealthResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method GetHealth not implemented")
 }
-
 func (UnimplementedAdminServiceServer) GetOverview(context.Context, *GetOverviewRequest) (*GetOverviewResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method GetOverview not implemented")
 }
-
 func (UnimplementedAdminServiceServer) ListQueues(context.Context, *ListQueuesRequest) (*ListQueuesResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method ListQueues not implemented")
 }
-
 func (UnimplementedAdminServiceServer) GetQueue(context.Context, *GetQueueRequest) (*GetQueueResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method GetQueue not implemented")
 }
-
 func (UnimplementedAdminServiceServer) UpdateQueueWeight(context.Context, *UpdateQueueWeightRequest) (*UpdateQueueWeightResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method UpdateQueueWeight not implemented")
 }
-
 func (UnimplementedAdminServiceServer) ResetQueueWeight(context.Context, *ResetQueueWeightRequest) (*ResetQueueWeightResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method ResetQueueWeight not implemented")
 }
-
 func (UnimplementedAdminServiceServer) PauseQueue(context.Context, *PauseQueueRequest) (*PauseQueueResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method PauseQueue not implemented")
 }
-
 func (UnimplementedAdminServiceServer) ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method ListJobs not implemented")
 }
-
 func (UnimplementedAdminServiceServer) ListJobEvents(context.Context, *ListJobEventsRequest) (*ListJobEventsResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method ListJobEvents not implemented")
 }
-
 func (UnimplementedAdminServiceServer) ListAuditEvents(context.Context, *ListAuditEventsRequest) (*ListAuditEventsResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method ListAuditEvents not implemented")
 }
-
 func (UnimplementedAdminServiceServer) GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method GetJob not implemented")
 }
-
 func (UnimplementedAdminServiceServer) UpsertJob(context.Context, *UpsertJobRequest) (*UpsertJobResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method UpsertJob not implemented")
 }
-
 func (UnimplementedAdminServiceServer) DeleteJob(context.Context, *DeleteJobRequest) (*DeleteJobResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method DeleteJob not implemented")
 }
-
 func (UnimplementedAdminServiceServer) RunJob(context.Context, *RunJobRequest) (*RunJobResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method RunJob not implemented")
 }
-
 func (UnimplementedAdminServiceServer) ListScheduleFactories(context.Context, *ListScheduleFactoriesRequest) (*ListScheduleFactoriesResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method ListScheduleFactories not implemented")
 }
-
 func (UnimplementedAdminServiceServer) ListScheduleEvents(context.Context, *ListScheduleEventsRequest) (*ListScheduleEventsResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method ListScheduleEvents not implemented")
 }
-
 func (UnimplementedAdminServiceServer) ListSchedules(context.Context, *ListSchedulesRequest) (*ListSchedulesResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method ListSchedules not implemented")
 }
-
 func (UnimplementedAdminServiceServer) CreateSchedule(context.Context, *CreateScheduleRequest) (*CreateScheduleResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method CreateSchedule not implemented")
 }
-
 func (UnimplementedAdminServiceServer) DeleteSchedule(context.Context, *DeleteScheduleRequest) (*DeleteScheduleResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method DeleteSchedule not implemented")
 }
-
 func (UnimplementedAdminServiceServer) PauseSchedule(context.Context, *PauseScheduleRequest) (*PauseScheduleResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method PauseSchedule not implemented")
 }
-
 func (UnimplementedAdminServiceServer) RunSchedule(context.Context, *RunScheduleRequest) (*RunScheduleResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method RunSchedule not implemented")
 }
-
 func (UnimplementedAdminServiceServer) PauseSchedules(context.Context, *PauseSchedulesRequest) (*PauseSchedulesResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method PauseSchedules not implemented")
 }
-
 func (UnimplementedAdminServiceServer) ListDLQ(context.Context, *ListDLQRequest) (*ListDLQResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method ListDLQ not implemented")
 }
-
 func (UnimplementedAdminServiceServer) GetDLQEntry(context.Context, *GetDLQEntryRequest) (*GetDLQEntryResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method GetDLQEntry not implemented")
 }
-
 func (UnimplementedAdminServiceServer) PauseDequeue(context.Context, *PauseDequeueRequest) (*PauseDequeueResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method PauseDequeue not implemented")
 }
-
 func (UnimplementedAdminServiceServer) ResumeDequeue(context.Context, *ResumeDequeueRequest) (*ResumeDequeueResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method ResumeDequeue not implemented")
 }
-
 func (UnimplementedAdminServiceServer) ReplayDLQ(context.Context, *ReplayDLQRequest) (*ReplayDLQResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method ReplayDLQ not implemented")
 }
-
 func (UnimplementedAdminServiceServer) ReplayDLQByID(context.Context, *ReplayDLQByIDRequest) (*ReplayDLQByIDResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method ReplayDLQByID not implemented")
 }
diff --git a/pkg/worker/v1/payload.pb.go b/pkg/worker/v1/payload.pb.go
index c5fe325..d3ac31d 100644
--- a/pkg/worker/v1/payload.pb.go
+++ b/pkg/worker/v1/payload.pb.go
@@ -7,12 +7,11 @@
 package workerpb
 
 import (
+	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
+	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
 	reflect "reflect"
 	sync "sync"
 	unsafe "unsafe"
-
-	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
-	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
 )
 
 const (
@@ -107,13 +106,10 @@ func file_worker_v1_payload_proto_rawDescGZIP() []byte {
 	return file_worker_v1_payload_proto_rawDescData
 }
 
-var (
-	file_worker_v1_payload_proto_msgTypes = make([]protoimpl.MessageInfo, 1)
-	file_worker_v1_payload_proto_goTypes  = []any{
-		(*SendEmailPayload)(nil), // 0: worker.v1.SendEmailPayload
-	}
-)
-
+var file_worker_v1_payload_proto_msgTypes = make([]protoimpl.MessageInfo, 1)
+var file_worker_v1_payload_proto_goTypes = []any{
+	(*SendEmailPayload)(nil), // 0: worker.v1.SendEmailPayload
+}
 var file_worker_v1_payload_proto_depIdxs = []int32{
 	0, // [0:0] is the sub-list for method output_type
 	0, // [0:0] is the sub-list for method input_type
diff --git a/pkg/worker/v1/worker.pb.go b/pkg/worker/v1/worker.pb.go
index f3a3f08..eb13ec6 100644
--- a/pkg/worker/v1/worker.pb.go
+++ b/pkg/worker/v1/worker.pb.go
@@ -7,14 +7,13 @@
 package workerpb
 
 import (
-	reflect "reflect"
-	sync "sync"
-	unsafe "unsafe"
-
 	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
 	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
 	anypb "google.golang.org/protobuf/types/known/anypb"
 	durationpb "google.golang.org/protobuf/types/known/durationpb"
+	reflect "reflect"
+	sync "sync"
+	unsafe "unsafe"
 )
 
 const (
@@ -801,28 +800,25 @@ func file_worker_v1_worker_proto_rawDescGZIP() []byte {
 	return file_worker_v1_worker_proto_rawDescData
 }
 
-var (
-	file_worker_v1_worker_proto_msgTypes = make([]protoimpl.MessageInfo, 14)
-	file_worker_v1_worker_proto_goTypes  = []any{
-		(*Task)(nil),                         // 0: worker.v1.Task
-		(*RegisterTasksRequest)(nil),         // 1: worker.v1.RegisterTasksRequest
-		(*RegisterTasksResponse)(nil),        // 2: worker.v1.RegisterTasksResponse
-		(*DurableTask)(nil),                  // 3: worker.v1.DurableTask
-		(*RegisterDurableTasksRequest)(nil),  // 4: worker.v1.RegisterDurableTasksRequest
-		(*RegisterDurableTasksResponse)(nil), // 5: worker.v1.RegisterDurableTasksResponse
-		(*StreamResultsRequest)(nil),         // 6: worker.v1.StreamResultsRequest
-		(*StreamResultsResponse)(nil),        // 7: worker.v1.StreamResultsResponse
-		(*CancelTaskRequest)(nil),            // 8: worker.v1.CancelTaskRequest
-		(*CancelTaskResponse)(nil),           // 9: worker.v1.CancelTaskResponse
-		(*GetTaskRequest)(nil),               // 10: worker.v1.GetTaskRequest
-		(*GetTaskResponse)(nil),              // 11: worker.v1.GetTaskResponse
-		nil,                                  // 12: worker.v1.Task.MetadataEntry
-		nil,                                  // 13: worker.v1.DurableTask.MetadataEntry
-		(*durationpb.Duration)(nil),          // 14: google.protobuf.Duration
-		(*anypb.Any)(nil),                    // 15: google.protobuf.Any
-	}
-)
-
+var file_worker_v1_worker_proto_msgTypes = make([]protoimpl.MessageInfo, 14)
+var file_worker_v1_worker_proto_goTypes = []any{
+	(*Task)(nil),                         // 0: worker.v1.Task
+	(*RegisterTasksRequest)(nil),         // 1: worker.v1.RegisterTasksRequest
+	(*RegisterTasksResponse)(nil),        // 2: worker.v1.RegisterTasksResponse
+	(*DurableTask)(nil),                  // 3: worker.v1.DurableTask
+	(*RegisterDurableTasksRequest)(nil),  // 4: worker.v1.RegisterDurableTasksRequest
+	(*RegisterDurableTasksResponse)(nil), // 5: worker.v1.RegisterDurableTasksResponse
+	(*StreamResultsRequest)(nil),         // 6: worker.v1.StreamResultsRequest
+	(*StreamResultsResponse)(nil),        // 7: worker.v1.StreamResultsResponse
+	(*CancelTaskRequest)(nil),            // 8: worker.v1.CancelTaskRequest
+	(*CancelTaskResponse)(nil),           // 9: worker.v1.CancelTaskResponse
+	(*GetTaskRequest)(nil),               // 10: worker.v1.GetTaskRequest
+	(*GetTaskResponse)(nil),              // 11: worker.v1.GetTaskResponse
+	nil,                                  // 12: worker.v1.Task.MetadataEntry
+	nil,                                  // 13: worker.v1.DurableTask.MetadataEntry
+	(*durationpb.Duration)(nil),          // 14: google.protobuf.Duration
+	(*anypb.Any)(nil),                    // 15: google.protobuf.Any
+}
 var file_worker_v1_worker_proto_depIdxs = []int32{
 	14, // 0: worker.v1.Task.retry_delay:type_name -> google.protobuf.Duration
 	15, // 1: worker.v1.Task.payload:type_name -> google.protobuf.Any
diff --git a/pkg/worker/v1/worker_grpc.pb.go b/pkg/worker/v1/worker_grpc.pb.go
index e6f1221..112bc81 100644
--- a/pkg/worker/v1/worker_grpc.pb.go
+++ b/pkg/worker/v1/worker_grpc.pb.go
@@ -8,7 +8,6 @@ package workerpb
 
 import (
 	context "context"
-
 	grpc "google.golang.org/grpc"
 	codes "google.golang.org/grpc/codes"
 	status "google.golang.org/grpc/status"
@@ -126,19 +125,15 @@ type UnimplementedWorkerServiceServer struct{}
 func (UnimplementedWorkerServiceServer) RegisterTasks(context.Context, *RegisterTasksRequest) (*RegisterTasksResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method RegisterTasks not implemented")
 }
-
 func (UnimplementedWorkerServiceServer) RegisterDurableTasks(context.Context, *RegisterDurableTasksRequest) (*RegisterDurableTasksResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method RegisterDurableTasks not implemented")
 }
-
 func (UnimplementedWorkerServiceServer) StreamResults(*StreamResultsRequest, grpc.ServerStreamingServer[StreamResultsResponse]) error {
 	return status.Error(codes.Unimplemented, "method StreamResults not implemented")
 }
-
 func (UnimplementedWorkerServiceServer) CancelTask(context.Context, *CancelTaskRequest) (*CancelTaskResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method CancelTask not implemented")
 }
-
 func (UnimplementedWorkerServiceServer) GetTask(context.Context, *GetTaskRequest) (*GetTaskResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method GetTask not implemented")
 }