style: cargo fmt for precompute worker tests and netflow e2e

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

Author: zzylol

asap-query-engine/src/precompute_engine/worker.rs

@@ -2495,11 +2495,7 @@ aggregations:
         // Idempotent: a window closed by the fallback drains its pane and its
         // wall-clock bookkeeping, so a subsequent flush must not re-emit.
         worker.flush_all().unwrap();
-        assert_eq!(
-            sink.len(),
-            0,
-            "already-closed window must not re-emit"
-        );
+        assert_eq!(sink.len(), 0, "already-closed window must not re-emit");
     }
 
     #[test]

asap-query-engine/tests/e2e_netflow_single_second.rs

@@ -111,8 +111,7 @@ async fn netflow_single_second_batch_is_not_lost_on_shutdown() {
     };
 
     let sink = Arc::new(CapturingOutputSink::new());
-    let sources: Vec<Box<dyn IngestSource>> =
-        vec![Box::new(JsonFileIngestSource::new(json_cfg))];
+    let sources: Vec<Box<dyn IngestSource>> = vec![Box::new(JsonFileIngestSource::new(json_cfg))];
     let engine = PrecomputeEngine::new(
         engine_config_grace_disabled(),
         streaming_config,
@@ -146,7 +145,11 @@ async fn netflow_single_second_batch_is_not_lost_on_shutdown() {
         output.start_timestamp,
         output.end_timestamp
     );
-    assert_eq!(output.start_timestamp % 1_000, 0, "window must be second-aligned");
+    assert_eq!(
+        output.start_timestamp % 1_000,
+        0,
+        "window must be second-aligned"
+    );
 
     let sum_acc = acc
         .as_any()