From 8543ecb30e529714fc3d4a0efecb926f5b52f790 Mon Sep 17 00:00:00 2001
From: discord9 <discord9@163.com>
Date: Mon, 7 Sep 2026 19:55:32 +0800
Subject: [PATCH] chore(flow): satisfy batching execution lint checks

Signed-off-by: discord9 <discord9@163.com>
---
 src/flow/src/batching_mode/engine.rs | 4 +++-
 src/flow/src/batching_mode/task.rs   | 1 +
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/flow/src/batching_mode/engine.rs b/src/flow/src/batching_mode/engine.rs
index 3f3c092c7b..e681a56c9e 100644
--- a/src/flow/src/batching_mode/engine.rs
+++ b/src/flow/src/batching_mode/engine.rs
@@ -1293,10 +1293,12 @@ mod tests {
         }
     }
 
+    type TestExecutionResult = crate::Result<Option<Arc<dyn crate::BatchingExecution>>>;
+
     struct TestExecutionFactory {
         entered: Option<Arc<Notify>>,
         release: Option<Arc<Notify>>,
-        result: std::sync::Mutex<Option<crate::Result<Option<Arc<dyn crate::BatchingExecution>>>>>,
+        result: std::sync::Mutex<Option<TestExecutionResult>>,
     }
 
     #[async_trait::async_trait]
diff --git a/src/flow/src/batching_mode/task.rs b/src/flow/src/batching_mode/task.rs
index 5fa80799a9..7f1e2fb633 100644
--- a/src/flow/src/batching_mode/task.rs
+++ b/src/flow/src/batching_mode/task.rs
@@ -1542,6 +1542,7 @@ impl BatchingTask {
         .await
     }
 
+    #[allow(clippy::too_many_arguments)]
     async fn gen_query_with_time_window_with_values(
         &self,
         engine: QueryEngineRef,