From aed5e70bbbef105e8814f51cc72672f98c4f731a Mon Sep 17 00:00:00 2001 From: piotrkosecki Date: Wed, 26 Jan 2022 16:58:18 +0100 Subject: [PATCH] fix --- .../indexer/tezos/forks/BacktracingForkProcessor.scala | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/conseil-lorre/src/main/scala/tech/cryptonomic/conseil/indexer/tezos/forks/BacktracingForkProcessor.scala b/conseil-lorre/src/main/scala/tech/cryptonomic/conseil/indexer/tezos/forks/BacktracingForkProcessor.scala index bfe8bcef5..d2fd4c1d0 100644 --- a/conseil-lorre/src/main/scala/tech/cryptonomic/conseil/indexer/tezos/forks/BacktracingForkProcessor.scala +++ b/conseil-lorre/src/main/scala/tech/cryptonomic/conseil/indexer/tezos/forks/BacktracingForkProcessor.scala @@ -7,6 +7,7 @@ import tech.cryptonomic.conseil.common.tezos.TezosTypes.{BlockData, TezosBlockHa import tech.cryptonomic.conseil.indexer.tezos.{TezosBlocksDataFetchers, TezosIndexedDataOperations, TezosRPCInterface} import cats._ import cats.implicits._ +import tech.cryptonomic.conseil.indexer.config.BatchFetchConfiguration import tech.cryptonomic.conseil.indexer.forks.ForkAmender import tech.cryptonomic.conseil.indexer.forks.ForkDetector.SearchBlockId @@ -27,13 +28,16 @@ class BacktracingForkProcessor( val node: TezosRPCInterface, tezosIndexedDataOperations: TezosIndexedDataOperations, indexerSearch: SearchBlockId[Future, TezosBlockHash], - amender: ForkAmender[Future, TezosBlockHash] + amender: ForkAmender[Future, TezosBlockHash], + batchConf: BatchFetchConfiguration, )(ec: ExecutionContext) extends TezosBlocksDataFetchers with ConseilLogSupport { + import batchConf.blockOperationsConcurrencyLevel + /** parallelism in the multiple requests decoding on the RPC interface */ - override def fetchConcurrency: Int = 50 + override def fetchConcurrency: Int = blockOperationsConcurrencyLevel implicit override def fetchFutureContext: ExecutionContext = ec