From b8826435686e600b7f2ed57722111797d4139f01 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=C3=96zg=C3=BCr=20Akkurt?=
 <91746947+ozgrakkurt@users.noreply.github.com>
Date: Sat, 4 Feb 2023 03:21:44 +0300
Subject: [PATCH] fix (#118)

---
 .DS_Store                             | Bin 0 -> 6148 bytes
 ingester/src/parquet_src/ver0_0_39.rs |  12 ++++--------
 2 files changed, 4 insertions(+), 8 deletions(-)
 create mode 100644 .DS_Store

diff --git a/.DS_Store b/.DS_Store
new file mode 100644
index 0000000000000000000000000000000000000000..256854b01db2ef9eba68afa5ec21d9e3f688c70b
GIT binary patch
literal 6148
zcmeHK%We}f6unM|c9N<niz0P{G!omWBr1K0O-Pdk3pNdc1)wm~8OkV=ag|KSB8rrC
z`w#pATfT&UVFl;fZj_m{D=I*huVf!T?y=*OYkN#YqBRa1L{%bkkr<r{vKx&1Ijva9
zv^)d~HHM^JN=VWf^;f)YgH^yP@V_a*d$&R-<kOJOv2z#u_hll_f<y-B=fmLz((W&1
zC>1#wm;*`*oNon=gL6S*o+$4p9^d8{Ohy;xH+&B+l6aKW>pw(k&3UlC;cmE_?uYJY
zIq7D8HXgP7;XAIqmNE&h%YN`CjwZe8_K8e0KTe~eBE(??m-lbuG?bH;9H-$(al5+1
zExYAjb!R$#R^O|6jibF;&6^${HEQ1B{=sZkb{{=?`uw!lPX?*HWHE63;rvs!W$+rV
zP*|+{OLv$iGCfBd`#Tgu_l*349?V(Rdg1r4_1Hf+gdWF#u7_E7L5~Wx&D{|pN<LAH
zyQCN^KMUHp@JbQ65sjcEczG>Lto5>%Tl5N=_u*;AN5tP8y&Umhmm<DQr_{kdXk&y9
zSOW_4a}me;GGm?pTeYtu%JRM{=JUQ2wKw>e71kg)9+rJky%RGr>u%o3Xm${*fK}i=
zDZuB0hs4-4IM=9-4rJ;H0Cdo-3}yaYV2)?7X>hI)JusoEKus0qi6Jx{?Vj;#8k}p?
zbQ0$AA<WFeyikOi9pih-okUZk&8-4ffxH51x?1J?zjOQhKTonXtAJJDUMV1)cDLQa
zlFZ$@vN*nLJ*1CFZ0tAJs3^$Hb*u_}74IM^L!ZY5VAJ4SBU)hgLqN%3GpoQ~Rp2*~
C1PAm0

literal 0
HcmV?d00001

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);