Skip to content

Commit a43b4f3

Browse files
style: apply rustfmt so CI fmt-check passes
Co-authored-by: Cursor <cursoragent@cursor.com>
1 parent 184c5dc commit a43b4f3

3 files changed

Lines changed: 3 additions & 12 deletions

File tree

src/controller/resources_test.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1729,8 +1729,7 @@ mod pdb_tests {
17291729
#[test]
17301730
fn test_non_validator_multi_replica_default_pdb() {
17311731
let node = node_with_replicas(NodeType::Horizon, 3);
1732-
let pdb =
1733-
build_pdb(&node).expect("PDB must be generated for multi-replica Horizon");
1732+
let pdb = build_pdb(&node).expect("PDB must be generated for multi-replica Horizon");
17341733
let spec = pdb.spec.unwrap();
17351734
assert_eq!(spec.max_unavailable, Some(IntOrString::Int(1)));
17361735
assert!(spec.min_available.is_none());

src/data_pipeline/quality.rs

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -182,13 +182,7 @@ impl DataQualityEngine {
182182
.metadata
183183
.get("date_partition")
184184
.map(|s| s.to_string())
185-
.unwrap_or_else(|| {
186-
r.pipeline_ts
187-
.split('T')
188-
.next()
189-
.unwrap_or("")
190-
.to_string()
191-
});
185+
.unwrap_or_else(|| r.pipeline_ts.split('T').next().unwrap_or("").to_string());
192186
let valid = date_partition.len() == 10
193187
&& date_partition.chars().nth(4) == Some('-')
194188
&& date_partition.chars().nth(7) == Some('-');

tests/admission_webhook_conformance.rs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -273,9 +273,7 @@ async fn conformance_null_spec_is_denied() {
273273
#[tokio::test]
274274
async fn conformance_none_object_is_admitted_with_no_plugins() {
275275
let server = new_server();
276-
let result = server
277-
.validate(make_input(Operation::Create, None))
278-
.await;
276+
let result = server.validate(make_input(Operation::Create, None)).await;
279277
// With no plugins and no object the server allows through
280278
assert!(
281279
result.allowed,

0 commit comments

Comments
 (0)