diff --git a/.DS_Store b/.DS_Store new file mode 100644 index 00000000..256854b0 Binary files /dev/null and b/.DS_Store differ diff --git a/ingester/src/parquet_src/ver0_0_39.rs b/ingester/src/parquet_src/ver0_0_39.rs index 6051986d..1a4078ec 100644 --- a/ingester/src/parquet_src/ver0_0_39.rs +++ b/ingester/src/parquet_src/ver0_0_39.rs @@ -100,14 +100,10 @@ fn stream_batches( let (mut blocks, txs, logs) = futures::future::try_join3(block_fut, tx_fut, log_fut).await?; - let mut block_range = Default::default(); - - for &num in blocks.keys() { - block_range += BlockRange { - from: num, - to: num + 1, - }; - } + let block_range = BlockRange { + from: *blocks.first_key_value().unwrap().0, + to: blocks.last_key_value().unwrap().0 + 1, + }; for tx in txs { blocks.get_mut(&tx.block_number.0).unwrap().transactions.push(tx);