Review comments

rust/index/src/spann/types.rs

@@ -1402,7 +1402,6 @@ impl ChromaError for SpannIndexReaderError {
 #[derive(Debug)]
 pub struct SpannPosting {
     pub doc_offset_id: u32,
-    pub doc_version: u32,
     pub doc_embedding: Vec<f32>,
 }
 
@@ -1540,7 +1539,6 @@ impl<'me> SpannIndexReader<'me> {
             }
             posting_lists.push(SpannPosting {
                 doc_offset_id: *doc_offset_id,
-                doc_version: res.doc_versions[index],
                 doc_embedding: res.doc_embeddings
                     [index * self.dimensionality..(index + 1) * self.dimensionality]
                     .to_vec(),

rust/worker/src/execution/operators/spann_fetch_pl.rs

@@ -4,7 +4,7 @@ use thiserror::Error;
 use tonic::async_trait;
 
 use crate::{
-    execution::operator::Operator,
+    execution::operator::{Operator, OperatorType},
     segment::spann_segment::{SpannSegmentReader, SpannSegmentReaderContext},
 };
 
@@ -14,6 +14,7 @@ pub struct SpannFetchPlInput {
     head_id: u32,
 }
 
+#[allow(dead_code)]
 #[derive(Debug)]
 pub struct SpannFetchPlOutput {
     posting_list: Vec<SpannPosting>,
@@ -40,6 +41,7 @@ impl ChromaError for SpannFetchPlError {
 pub struct SpannFetchPlOperator {}
 
 impl SpannFetchPlOperator {
+    #[allow(dead_code)]
     pub fn new() -> Box<Self> {
         Box::new(SpannFetchPlOperator {})
     }
@@ -67,4 +69,9 @@ impl Operator<SpannFetchPlInput, SpannFetchPlOutput> for SpannFetchPlOperator {
             .map_err(|_| SpannFetchPlError::SpannSegmentReaderError)?;
         Ok(SpannFetchPlOutput { posting_list })
     }
+
+    // This operator is IO bound.
+    fn get_type(&self) -> OperatorType {
+        OperatorType::IO
+    }
 }

rust/worker/src/segment/spann_segment.rs

@@ -8,8 +8,8 @@ use chroma_index::spann::types::{
 };
 use chroma_index::IndexUuid;
 use chroma_index::{hnsw_provider::HnswIndexProvider, spann::types::SpannIndexWriter};
+use chroma_types::SegmentUuid;
 use chroma_types::{MaterializedLogOperation, Segment, SegmentScope, SegmentType};
-use chroma_types::{SegmentUuid, SpannPostingList};
 use thiserror::Error;
 use tonic::async_trait;
 use uuid::Uuid;