diff --git a/idl/chromadb/proto/compactor.proto b/idl/chromadb/proto/compactor.proto
index c64d6810879..1541e4144f4 100644
--- a/idl/chromadb/proto/compactor.proto
+++ b/idl/chromadb/proto/compactor.proto
@@ -7,7 +7,7 @@ message CollectionIds {
 }
 
 message CompactionRequest {
-  optional CollectionIds ids = 1;
+  CollectionIds ids = 1;
 }
 
 message CompactionResponse {
diff --git a/rust/worker/src/compactor/types.rs b/rust/worker/src/compactor/types.rs
index 80de3641588..2f1b5411952 100644
--- a/rust/worker/src/compactor/types.rs
+++ b/rust/worker/src/compactor/types.rs
@@ -14,5 +14,5 @@ pub struct ScheduledCompactionMessage {}
 #[derive(Clone, Debug)]
 pub struct OneOffCompactionMessage {
     #[allow(dead_code)]
-    pub collection_ids: Option<Vec<CollectionUuid>>,
+    pub collection_ids: Vec<CollectionUuid>,
 }
diff --git a/rust/worker/src/utils/convert.rs b/rust/worker/src/utils/convert.rs
index ffe442249e6..2a2f111ebbf 100644
--- a/rust/worker/src/utils/convert.rs
+++ b/rust/worker/src/utils/convert.rs
@@ -167,13 +167,11 @@ impl TryFrom<chroma_proto::CompactionRequest> for OneOffCompactionMessage {
         Ok(Self {
             collection_ids: value
                 .ids
-                .map(|ids| {
-                    ids.ids
-                        .into_iter()
-                        .map(|id| CollectionUuid::from_str(&id))
-                        .collect::<Result<_, _>>()
-                })
-                .transpose()
+                .ok_or(ConversionError::DecodeError)?
+                .ids
+                .into_iter()
+                .map(|id| CollectionUuid::from_str(&id))
+                .collect::<Result<_, _>>()
                 .map_err(|_| ConversionError::DecodeError)?,
         })
     }