Skip to content

Commit

Permalink
Remove dead codes
Browse files Browse the repository at this point in the history
  • Loading branch information
Sicheng Pan authored and Sicheng-Pan committed Dec 11, 2024
1 parent 9287004 commit ba40c1a
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 23 deletions.
1 change: 0 additions & 1 deletion rust/worker/src/execution/operator.rs
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,6 @@ where
#[derive(Debug)]
pub(super) struct TaskResult<Output, Error> {
result: Result<Output, TaskError<Error>>,
#[allow(dead_code)]
task_id: Uuid,
}

Expand Down
22 changes: 0 additions & 22 deletions rust/worker/src/segment/record_segment.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down Expand Up @@ -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)]
Expand Down

0 comments on commit ba40c1a

Please sign in to comment.