diff --git a/rust/worker/src/execution/operator.rs b/rust/worker/src/execution/operator.rs
index b977ae9e08d..d82aaaec501 100644
--- a/rust/worker/src/execution/operator.rs
+++ b/rust/worker/src/execution/operator.rs
@@ -65,7 +65,6 @@ where
 #[derive(Debug)]
 pub(super) struct TaskResult<Output, Error> {
     result: Result<Output, TaskError<Error>>,
-    #[allow(dead_code)]
     task_id: Uuid,
 }
 
diff --git a/rust/worker/src/segment/record_segment.rs b/rust/worker/src/segment/record_segment.rs
index 1553bf4a04e..f69ad5e7f04 100644
--- a/rust/worker/src/segment/record_segment.rs
+++ b/rust/worker/src/segment/record_segment.rs
@@ -774,20 +774,6 @@ impl RecordSegmentReader<'_> {
         self.curr_max_offset_id.clone()
     }
 
-    #[allow(dead_code)]
-    pub(crate) async fn get_user_id_for_offset_id(
-        &self,
-        offset_id: u32,
-    ) -> Result<&str, Box<dyn ChromaError>> {
-        match self.id_to_user_id.get("", offset_id).await {
-            Ok(Some(user_id)) => Ok(user_id),
-            Ok(None) => Err(Box::new(
-                RecordSegmentReaderCreationError::UserRecordNotFound(offset_id.to_string()),
-            )),
-            Err(e) => Err(e),
-        }
-    }
-
     pub(crate) async fn get_offset_id_for_user_id(
         &self,
         user_id: &str,
@@ -940,14 +926,6 @@ impl RecordSegmentReader<'_> {
             .load_blocks_for_keys(&prefixes, &keys)
             .await
     }
-
-    #[allow(dead_code)]
-    pub(crate) async fn prefetch_id_to_user_id(&self, keys: &[u32]) {
-        let prefixes = vec![""; keys.len()];
-        self.id_to_user_id
-            .load_blocks_for_keys(&prefixes, keys)
-            .await
-    }
 }
 
 #[cfg(test)]