diff --git a/internal/queue/queue.go b/internal/queue/queue.go
index d0eb8b02a3..80047dec4a 100644
--- a/internal/queue/queue.go
+++ b/internal/queue/queue.go
@@ -32,6 +32,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),