Fix logic of get latest fully fetched block from partitions

enviodev · Sep 10, 2024 · 0ca00a4 · 0ca00a4
1 parent 655e4d8
commit 0ca00a4
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/codegenerator/cli/templates/static/codegen/src/eventFetching/ChainFetcher.res b/codegenerator/cli/templates/static/codegen/src/eventFetching/ChainFetcher.res
@@ -285,7 +285,6 @@ let hasProcessedToEndblock = (self: t) => {
 
 let hasNoMoreEventsToProcess = (self: t, ~hasArbQueueEvents) => {
   !hasArbQueueEvents &&
-  !self.isFetchingBatch &&
   self.fetchState->PartitionedFetchState.queueSize === 0
 }
 

diff --git a/codegenerator/cli/templates/static/codegen/src/eventFetching/PartitionedFetchState.res b/codegenerator/cli/templates/static/codegen/src/eventFetching/PartitionedFetchState.res
@@ -231,7 +231,7 @@ let getLatestFullyFetchedBlock = ({partitions}: t) =>
     let partitionBlock = partition->FetchState.getLatestFullyFetchedBlock
     switch accum {
     | Some({FetchState.blockNumber: blockNumber})
-      if partitionBlock.blockNumber < blockNumber => accum
+      if partitionBlock.blockNumber >= blockNumber => accum
     | _ => Some(partitionBlock)
     }
   })