@@ -895,29 +895,28 @@ let checkAndFetchForChain = (
895895 dispatchAction (FinishWaitingForNewBlock ({chain , currentBlockHeight }))
896896 }
897897 | (queries , _ ) =>
898- let maxNumQueries = Pervasives .max (
899- Env .maxPartitionConcurrency - partitionsCurrentlyFetching -> Belt .Set .Int .size ,
900- 0 ,
901- )
902- let queries = queries -> Js .Array2 .slice (~start = 0 , ~end_ = maxNumQueries )
903- let newPartitionsCurrentlyFetching =
904- queries -> Array .map (query => query .partitionId )-> Set .Int .fromArray
905- dispatchAction (SetCurrentlyFetchingBatch (chain , newPartitionsCurrentlyFetching ))
906- let isPreRegisteringDynamicContracts =
907- state .chainManager -> ChainManager .isPreRegisteringDynamicContracts
908- let _ =
909- await queries
910- -> Array .map (query =>
911- query -> executePartitionQuery (
912- ~logger ,
913- ~chainWorker ,
914- ~currentBlockHeight ,
915- ~chain ,
916- ~dispatchAction ,
917- ~isPreRegisteringDynamicContracts ,
898+ let maxQueriesNumber = Env .maxPartitionConcurrency - partitionsCurrentlyFetching -> Belt .Set .Int .size
899+ if maxQueriesNumber > 0 {
900+ let queries = queries -> Js .Array2 .slice (~start = 0 , ~end_ = maxQueriesNumber )
901+ let newPartitionsCurrentlyFetching =
902+ queries -> Array .map (query => query .partitionId )-> Set .Int .fromArray
903+ dispatchAction (SetCurrentlyFetchingBatch (chain , newPartitionsCurrentlyFetching ))
904+ let isPreRegisteringDynamicContracts =
905+ state .chainManager -> ChainManager .isPreRegisteringDynamicContracts
906+ let _ =
907+ await queries
908+ -> Array .map (query =>
909+ query -> executePartitionQuery (
910+ ~logger ,
911+ ~chainWorker ,
912+ ~currentBlockHeight ,
913+ ~chain ,
914+ ~dispatchAction ,
915+ ~isPreRegisteringDynamicContracts ,
916+ )
918917 )
919- )
920- -> Promise . all
918+ -> Promise . all
919+ }
921920 }
922921 }
923922}
0 commit comments