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,