From a922f472bdb2570a22bf7934179cf56b183db1af Mon Sep 17 00:00:00 2001
From: Darun Seethammagari <darunrs@gmail.com>
Date: Wed, 14 Feb 2024 18:49:25 -0800
Subject: [PATCH] fix: Remove throwing of error during intended retry loop

---
 runner/src/stream-handler/worker.ts | 1 -
 1 file changed, 1 deletion(-)

diff --git a/runner/src/stream-handler/worker.ts b/runner/src/stream-handler/worker.ts
index 0b16ec185..ce73e646b 100644
--- a/runner/src/stream-handler/worker.ts
+++ b/runner/src/stream-handler/worker.ts
@@ -135,7 +135,6 @@ async function blockQueueConsumer (workerContext: WorkerContext, streamKey: stri
     } catch (err) {
       await sleep(10000);
       console.log(`Failed: ${indexerName} ${workerContext.streamType} on block ${currBlockHeight}`, err);
-      throw err;
     } finally {
       const unprocessedMessageCount = await workerContext.redisClient.getUnprocessedStreamMessageCount(streamKey);
       METRICS.UNPROCESSED_STREAM_MESSAGES.labels({ indexer: indexerName, type: workerContext.streamType }).set(unprocessedMessageCount);