Skip to content

Commit c85a329

Browse files
committed
fix: run rustfmt
1 parent a1f4120 commit c85a329

2 files changed

Lines changed: 9 additions & 19 deletions

File tree

src/metadata_writer.rs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -342,7 +342,7 @@ mod tests {
342342
match result {
343343
Err(DuckLakeError::InvalidConfig(msg)) => {
344344
assert!(msg.contains("empty"), "Expected 'empty' in: {msg}");
345-
}
345+
},
346346
other => panic!("Expected InvalidConfig, got {:?}", other),
347347
}
348348
}
@@ -357,7 +357,7 @@ mod tests {
357357
msg.contains("control character"),
358358
"Expected 'control character' in: {msg}"
359359
);
360-
}
360+
},
361361
other => panic!("Expected InvalidConfig, got {:?}", other),
362362
}
363363
}
@@ -369,7 +369,7 @@ mod tests {
369369
match result {
370370
Err(DuckLakeError::InvalidConfig(msg)) => {
371371
assert!(msg.contains("empty"), "Expected 'empty' in: {msg}");
372-
}
372+
},
373373
other => panic!("Expected InvalidConfig, got {:?}", other),
374374
}
375375
}
@@ -384,7 +384,7 @@ mod tests {
384384
msg.contains("control character"),
385385
"Expected 'control character' in: {msg}"
386386
);
387-
}
387+
},
388388
other => panic!("Expected InvalidConfig, got {:?}", other),
389389
}
390390
}
@@ -439,7 +439,7 @@ mod tests {
439439
msg.contains("exceeds maximum length"),
440440
"Expected 'exceeds maximum length' in: {msg}"
441441
);
442-
}
442+
},
443443
other => panic!("Expected InvalidConfig, got {:?}", other),
444444
}
445445
}

src/metadata_writer_sqlite.rs

Lines changed: 4 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -662,10 +662,7 @@ mod tests {
662662
let result = writer.get_or_create_schema("", None, snapshot_id);
663663
assert!(result.is_err());
664664
let err_msg = format!("{}", result.unwrap_err());
665-
assert!(
666-
err_msg.contains("empty"),
667-
"Expected 'empty' in: {err_msg}"
668-
);
665+
assert!(err_msg.contains("empty"), "Expected 'empty' in: {err_msg}");
669666
}
670667

671668
#[tokio::test(flavor = "multi_thread")]
@@ -688,24 +685,17 @@ mod tests {
688685
let result = writer.begin_write_transaction("", "table", &columns, WriteMode::Replace);
689686
assert!(result.is_err());
690687
let err_msg = format!("{}", result.unwrap_err());
691-
assert!(
692-
err_msg.contains("empty"),
693-
"Expected 'empty' in: {err_msg}"
694-
);
688+
assert!(err_msg.contains("empty"), "Expected 'empty' in: {err_msg}");
695689
}
696690

697691
#[tokio::test(flavor = "multi_thread")]
698692
async fn test_begin_write_transaction_empty_table_name_rejected() {
699693
let (writer, _temp) = create_test_writer().await;
700694
let columns = vec![ColumnDef::new("id", "int64", false).unwrap()];
701-
let result =
702-
writer.begin_write_transaction("main", "", &columns, WriteMode::Replace);
695+
let result = writer.begin_write_transaction("main", "", &columns, WriteMode::Replace);
703696
assert!(result.is_err());
704697
let err_msg = format!("{}", result.unwrap_err());
705-
assert!(
706-
err_msg.contains("empty"),
707-
"Expected 'empty' in: {err_msg}"
708-
);
698+
assert!(err_msg.contains("empty"), "Expected 'empty' in: {err_msg}");
709699
}
710700

711701
#[tokio::test(flavor = "multi_thread")]

0 commit comments

Comments
 (0)