fix(flow): resolve incremental state clippy warnings

Signed-off-by: discord9 <discord9@163.com>
This commit is contained in:
discord9
2026-09-05 03:36:51 +08:00
parent f7befc1776
commit 613c1c675d
2 changed files with 7 additions and 8 deletions
+6 -7
View File
@@ -769,13 +769,12 @@ impl BatchingEngine {
let persistence = if let Some(factory) = &self.persistence_factory {
let table_info = table.table_info();
let meta = &table_info.meta;
let effective_mode = if task.config.exact_sequence_range_required {
crate::IncrementalMode::SequenceRange
} else if task.config.batch_opts.experimental_enable_incremental_read
&& task
.sequence_range_capable()
.await
.is_ok_and(|capable| capable)
let effective_mode = if task.config.exact_sequence_range_required
|| (task.config.batch_opts.experimental_enable_incremental_read
&& task
.sequence_range_capable()
.await
.is_ok_and(|capable| capable))
{
crate::IncrementalMode::SequenceRange
} else {
+1 -1
View File
@@ -547,7 +547,7 @@ pub fn analyze_incremental_aggregate_plan(
merge_columns.push(IncrementalAggregateMergeColumn {
input_field_name: input_field_name.clone(),
output_field_name,
merge_op: merge_op.clone(),
merge_op,
});
}
}