diff --git a/internal/store/queuestore.go b/internal/store/queuestore.go
index 1ee6278bb..2fb2ac475 100644
--- a/internal/store/queuestore.go
+++ b/internal/store/queuestore.go
@@ -242,6 +242,10 @@ func (store *QueueStore[I]) GetRaw(key Key) (raw []byte, err error) {
 		return raw, os.ErrNotExist
 	}
 
+	if key.Compress {
+		raw, err = s2.Decode(nil, raw)
+	}
+
 	return
 }