fix: Ensure historical invocations are configured correctly

near · Nov 13, 2023 · bc975ea · bc975ea
1 parent 530efd3
commit bc975ea
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/runner/src/stream-handler/worker.ts b/runner/src/stream-handler/worker.ts
@@ -105,21 +105,22 @@ async function blockQueueConsumer (workerContext: WorkerContext, streamKey: stri
       const startTime = performance.now();
       const blockStartTime = startTime;
       const block = queueMessage.block;
+      const isHistorical = workerContext.streamType === 'historical';
       streamMessageId = queueMessage.streamMessageId;
 
       if (block === undefined || block.blockHeight == null) {
         console.error('Block failed to process or does not have block height', block);
         continue;
       }
       METRICS.BLOCK_WAIT_DURATION.labels({ indexer: indexerName, type: workerContext.streamType }).set(performance.now() - blockStartTime);
-      await indexer.runFunctions(block, functions, false, { provision: true });
+      await indexer.runFunctions(block, functions, isHistorical, { provision: true });
 
       await workerContext.redisClient.deleteStreamMessage(streamKey, streamMessageId);
       await workerContext.queue.shift();
 
       METRICS.EXECUTION_DURATION.labels({ indexer: indexerName, type: workerContext.streamType }).observe(performance.now() - startTime);
 
-      if (workerContext.streamType === 'historical') {
+      if (isHistorical) {
         METRICS.LAST_PROCESSED_BLOCK_HEIGHT.labels({ indexer: indexerName, type: workerContext.streamType }).set(block.blockHeight);
       }