Skip to content

Commit

Permalink
fix: remove stray dbg!
Browse files Browse the repository at this point in the history
  • Loading branch information
mgattozzi committed Dec 2, 2024
1 parent 719d9c4 commit 0e88bec
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 8 deletions.
8 changes: 3 additions & 5 deletions influxdb3_write/src/persister.rs
Original file line number Diff line number Diff line change
Expand Up @@ -298,11 +298,9 @@ impl Persister {
persisted_snapshot.snapshot_sequence_number,
);
let json = serde_json::to_vec_pretty(persisted_snapshot)?;
dbg!(
self.object_store
.put(snapshot_file_path.as_ref(), json.into())
.await
)?;
self.object_store
.put(snapshot_file_path.as_ref(), json.into())
.await?;
Ok(())
}

Expand Down
2 changes: 0 additions & 2 deletions influxdb3_write/src/write_buffer/queryable_buffer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -504,8 +504,6 @@ impl BufferState {
let table_def = db_schema
.table_definition_by_id(&table_id)
.expect("table should exist");
// TODO: can we have the primary key stored on the table definition (we already have
// the series key, so that doesn't seem like too much of a stretch).
let sort_key = table_def
.series_key
.iter()
Expand Down
2 changes: 1 addition & 1 deletion influxdb3_write/src/write_buffer/validator.rs
Original file line number Diff line number Diff line change
Expand Up @@ -265,7 +265,7 @@ fn validate_and_qualify_v3_line(
let qualified = if let Some(table_def) = db_schema.table_definition(table_name) {
let table_id = table_def.table_id;
// TODO: may be faster to compare using table def/column IDs than comparing with schema:
match dbg!((table_def.series_key(), &line.series.series_key)) {
match (table_def.series_key(), &line.series.series_key) {
(s, Some(l)) => {
let l = l.iter().map(|sk| sk.0.as_str()).collect::<Vec<&str>>();
if s != l {
Expand Down

0 comments on commit 0e88bec

Please sign in to comment.