From 6fadf13ed367e83f198a876333f9b2b7f26599fb Mon Sep 17 00:00:00 2001 From: pmantica11 <151664502+pmantica11@users.noreply.github.com> Date: Sat, 14 Sep 2024 09:40:28 -0400 Subject: [PATCH] Fix gRPC (#203) --- src/ingester/fetchers/grpc.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/ingester/fetchers/grpc.rs b/src/ingester/fetchers/grpc.rs index 60e25fa8..1d19c755 100644 --- a/src/ingester/fetchers/grpc.rs +++ b/src/ingester/fetchers/grpc.rs @@ -107,9 +107,6 @@ pub fn get_grpc_stream_with_rpc_fallback( continue; } }; - if block.metadata.slot == 0 { - continue; - } if block.metadata.parent_slot == last_indexed_slot { last_indexed_slot = block.metadata.slot; yield vec![block]; @@ -186,7 +183,10 @@ fn get_grpc_block_stream( match message { Ok(message) => match message.update_oneof { Some(UpdateOneof::Block(block)) => { - yield parse_block(block); + let block = parse_block(block); + if block.metadata.slot != 0 { + yield block; + } } Some(UpdateOneof::Ping(_)) => { // This is necessary to keep load balancers that expect client pings alive. If your load balancer doesn't