Skip to content

Commit dfc421e

Browse files
committed
fix: run rustfmt
1 parent a1ad17b commit dfc421e

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
@@ -672,10 +672,7 @@ mod tests {
672672
let result = writer.get_or_create_schema("", None, snapshot_id);
673673
assert!(result.is_err());
674674
let err_msg = format!("{}", result.unwrap_err());
675-
assert!(
676-
err_msg.contains("empty"),
677-
"Expected 'empty' in: {err_msg}"
678-
);
675+
assert!(err_msg.contains("empty"), "Expected 'empty' in: {err_msg}");
679676
}
680677

681678
#[tokio::test(flavor = "multi_thread")]
@@ -698,24 +695,17 @@ mod tests {
698695
let result = writer.begin_write_transaction("", "table", &columns, WriteMode::Replace);
699696
assert!(result.is_err());
700697
let err_msg = format!("{}", result.unwrap_err());
701-
assert!(
702-
err_msg.contains("empty"),
703-
"Expected 'empty' in: {err_msg}"
704-
);
698+
assert!(err_msg.contains("empty"), "Expected 'empty' in: {err_msg}");
705699
}
706700

707701
#[tokio::test(flavor = "multi_thread")]
708702
async fn test_begin_write_transaction_empty_table_name_rejected() {
709703
let (writer, _temp) = create_test_writer().await;
710704
let columns = vec![ColumnDef::new("id", "int64", false).unwrap()];
711-
let result =
712-
writer.begin_write_transaction("main", "", &columns, WriteMode::Replace);
705+
let result = writer.begin_write_transaction("main", "", &columns, WriteMode::Replace);
713706
assert!(result.is_err());
714707
let err_msg = format!("{}", result.unwrap_err());
715-
assert!(
716-
err_msg.contains("empty"),
717-
"Expected 'empty' in: {err_msg}"
718-
);
708+
assert!(err_msg.contains("empty"), "Expected 'empty' in: {err_msg}");
719709
}
720710

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

0 commit comments

Comments
 (0)