rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-05-18 14:00:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

style: fix clippy

Browse Source
This commit is contained in:
evenyag
2025-04-24 05:55:24 +08:00
parent 68414bf593
commit f35e957ddd
1 changed files with 4 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/mito2/src/read/series_scan.rs
View File

@@ -341,7 +341,7 @@ impl SeriesDistributor {
for part_range in partition {
build_sources(
&self.stream_ctx,
&part_range,
part_range,
false,
&part_metrics,
range_builder_list.clone(),
@@ -386,7 +386,6 @@ impl SeriesDistributor {
metrics.yield_cost += yield_start.elapsed();
}
// todo: if not empty
if !current_series.is_empty() {
let yield_start = Instant::now();
self.senders.send_batch(current_series).await?;
@@ -527,11 +526,9 @@ impl SenderList {
async fn send_error(&self, error: Error) {
let error = Arc::new(error);
for sender in &self.senders {
if let Some(sender) = sender {
let result = Err(error.clone()).context(ScanSeriesSnafu);
let _ = sender.send(result).await;
}
for sender in self.senders.iter().flatten() {
let result = Err(error.clone()).context(ScanSeriesSnafu);
let _ = sender.send(result).await;
}
}