[ci] apply automatic fixes

feldera-bot · feldera-bot · commit 9f168a877db7 · 2026-04-07T16:41:36.000Z
Signed-off-by: feldera-bot &lt;feldera-bot@feldera.com&gt;
diff --git a/crates/adapters/src/controller.rs b/crates/adapters/src/controller.rs
@@ -3125,9 +3125,7 @@ impl CircuitThread {
         if *self.checkpoint_sender.borrow() != checkpoint_coordination {
             let now_ms = Utc::now().timestamp_millis();
             match &checkpoint_coordination {
-                Some(
-                    CheckpointCoordination::Delayed(_) | CheckpointCoordination::Barriers(_),
-                ) => {
+                Some(CheckpointCoordination::Delayed(_) | CheckpointCoordination::Barriers(_)) => {
                     // Only set the delay start time on the first transition
                     // into a delayed state (not on subsequent reason changes).
                     self.controller
@@ -3153,8 +3151,7 @@ impl CircuitThread {
                         .store(0, Ordering::Release);
                 }
             }
-            self.checkpoint_sender
-                .send_replace(checkpoint_coordination);
+            self.checkpoint_sender.send_replace(checkpoint_coordination);
         }
     }
 
diff --git a/crates/adapters/src/server.rs b/crates/adapters/src/server.rs
@@ -61,8 +61,7 @@ use feldera_types::completion_token::{
 };
 use feldera_types::constants::STATUS_FILE;
 use feldera_types::coordination::{
-    AdHocScan, CoordinationActivate, CoordinationStatus, Labels,
-    RestartArgs, Step, StepRequest,
+    AdHocScan, CoordinationActivate, CoordinationStatus, Labels, RestartArgs, Step, StepRequest,
 };
 use feldera_types::pipeline_diff::PipelineDiff;
 use feldera_types::query_params::{

Original file line number	Diff line number	Diff line change
`@@ -3125,9 +3125,7 @@ impl CircuitThread {`
`3125`	`3125`	`if *self.checkpoint_sender.borrow() != checkpoint_coordination {`
`3126`	`3126`	`let now_ms = Utc::now().timestamp_millis();`
`3127`	`3127`	`match &checkpoint_coordination {`
`3128`		`- Some(`
`3129`		`- CheckpointCoordination::Delayed(_) \| CheckpointCoordination::Barriers(_),`
`3130`		`- ) => {`
	`3128`	`+ Some(CheckpointCoordination::Delayed(_) \| CheckpointCoordination::Barriers(_)) => {`
`3131`	`3129`	`// Only set the delay start time on the first transition`
`3132`	`3130`	`// into a delayed state (not on subsequent reason changes).`
`3133`	`3131`	`self.controller`
`@@ -3153,8 +3151,7 @@ impl CircuitThread {`
`3153`	`3151`	`.store(0, Ordering::Release);`
`3154`	`3152`	`}`
`3155`	`3153`	`}`
`3156`		`- self.checkpoint_sender`
`3157`		`- .send_replace(checkpoint_coordination);`
	`3154`	`+ self.checkpoint_sender.send_replace(checkpoint_coordination);`
`3158`	`3155`	`}`
`3159`	`3156`	`}`
`3160`	`3157`