[ci] apply automatic fixes

feldera-bot · feldera-bot · commit 0fa760f26cb4 · 2026-04-09T09:37:57.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
@@ -3124,9 +3124,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
@@ -3152,8 +3150,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::{
diff --git a/openapi.json b/openapi.json
@@ -6793,17 +6793,10 @@
             "type": "object",
             "description": "A checkpoint is currently being written to storage.",
             "required": [
-              "sequence_number",
               "started_at",
               "status"
             ],
             "properties": {
-              "sequence_number": {
-                "type": "integer",
-                "format": "int64",
-                "description": "Sequence number of the in-flight checkpoint.",
-                "minimum": 0
-              },
               "started_at": {
                 "type": "string",
                 "format": "date-time",

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