Skip to content

Commit a9979ce

Browse files
committed
minor refactor
1 parent 5329a59 commit a9979ce

1 file changed

Lines changed: 7 additions & 7 deletions

File tree

  • quickwit/quickwit-metastore/src/metastore/file_backed/file_backed_index

quickwit/quickwit-metastore/src/metastore/file_backed/file_backed_index/mod.rs

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1044,13 +1044,6 @@ fn metrics_split_matches_query(split: &StoredMetricsSplit, query: &ListMetricsSp
10441044
return false;
10451045
}
10461046

1047-
// Filter by max time_range_end (retention policy: splits whose data ends before cutoff)
1048-
if let Some(max_time_range_end) = query.max_time_range_end
1049-
&& (split.metadata.time_range.end_secs as i64) > max_time_range_end
1050-
{
1051-
return false;
1052-
}
1053-
10541047
if let Some(node_id) = &query.node_id
10551048
&& split.node_id != *node_id
10561049
{
@@ -1083,6 +1076,13 @@ fn metrics_split_matches_query(split: &StoredMetricsSplit, query: &ListMetricsSp
10831076
Bound::Unbounded => {}
10841077
}
10851078

1079+
// Filter by max time_range_end (retention policy: splits whose data ends before cutoff)
1080+
if let Some(max_time_range_end) = query.max_time_range_end
1081+
&& (split.metadata.time_range.end_secs as i64) > max_time_range_end
1082+
{
1083+
return false;
1084+
}
1085+
10861086
true
10871087
}
10881088

0 commit comments

Comments
 (0)