chore(flow): satisfy batching execution lint checks

Signed-off-by: discord9 <discord9@163.com>
This commit is contained in:
discord9
2026-09-07 19:55:32 +08:00
parent 5f91fa9589
commit 8543ecb30e
2 changed files with 4 additions and 1 deletions
+3 -1
View File
@@ -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]
+1
View File
@@ -1542,6 +1542,7 @@ impl BatchingTask {
.await
}
#[allow(clippy::too_many_arguments)]
async fn gen_query_with_time_window_with_values(
&self,
engine: QueryEngineRef,