diff --git a/internal/queue/queue.go b/internal/queue/queue.go
index 3fde54aa3..818524fd2 100644
--- a/internal/queue/queue.go
+++ b/internal/queue/queue.go
@@ -33,6 +33,7 @@ type Config struct {
 func NewQueue(config *Config) (_ *Queue, err error) {
 	middleware := []rivertype.Middleware{otelriver.NewMiddleware(&otelriver.MiddlewareConfig{
 		MeterProvider: metrics.GetMetricsProvider(),
+		DurationUnit:  "ms",
 	})}
 	return &Queue{
 		driver: riverdatabasesql.New(config.Client.DB),