From d76ba6cb1eb3dd770eff7f54cca58379db469e5d Mon Sep 17 00:00:00 2001 From: discord9 <55937128+discord9@users.noreply.github.com> Date: Tue, 15 Sep 2026 17:46:11 +0800 Subject: [PATCH] style: format exact sequence recovery tests Signed-off-by: discord9 <55937128+discord9@users.noreply.github.com> --- src/flow/src/batching_mode/task/test.rs | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/src/flow/src/batching_mode/task/test.rs b/src/flow/src/batching_mode/task/test.rs index fbb8e189917..8db13a0f8b5 100644 --- a/src/flow/src/batching_mode/task/test.rs +++ b/src/flow/src/batching_mode/task/test.rs @@ -2168,7 +2168,10 @@ async fn test_exact_required_executed_failure_selects_full_snapshot_repair() { .await .unwrap() .unwrap(); - assert!(matches!(plan_info.coverage, QueryCoverage::IncrementalDelta)); + assert!(matches!( + plan_info.coverage, + QueryCoverage::IncrementalDelta + )); let handler: Arc = Arc::new(ExactDeltaFailureHandler); @@ -2389,9 +2392,9 @@ async fn test_exact_required_unsupported_plan_keeps_exact_retry_state() { .unwrap(); let dml_plan = LogicalPlan::Dml(DmlStatement::new( datafusion_common::TableReference::bare("test"), - Arc::new(DefaultTableSource::new(Arc::new(DfTableProviderAdapter::new( - sink_table, - )))), + Arc::new(DefaultTableSource::new(Arc::new( + DfTableProviderAdapter::new(sink_table), + ))), WriteOp::Insert(datafusion_expr::dml::InsertOp::Append), Arc::new(plan), ));