From 4e785d4549116cde285a615b76621bb9b75ffcc9 Mon Sep 17 00:00:00 2001 From: hatemosphere Date: Fri, 13 Oct 2023 14:41:15 +0200 Subject: [PATCH] Further limit batch sizes to 50 --- apps/indexer/lib/indexer/block/catchup/fetcher.ex | 2 +- apps/indexer/lib/indexer/block/fetcher.ex | 2 +- apps/indexer/lib/indexer/fetcher/token_balance.ex | 2 +- apps/indexer/lib/indexer/temporary/uncles_without_index.ex | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/apps/indexer/lib/indexer/block/catchup/fetcher.ex b/apps/indexer/lib/indexer/block/catchup/fetcher.ex index a4cdbbfb5f47..93dfeca104e3 100644 --- a/apps/indexer/lib/indexer/block/catchup/fetcher.ex +++ b/apps/indexer/lib/indexer/block/catchup/fetcher.ex @@ -34,7 +34,7 @@ defmodule Indexer.Block.Catchup.Fetcher do # DO NOT use them directly in the code. Get options from `state`. @blocks_batch_size 10 - @blocks_concurrency 5 + @blocks_concurrency 10 @sequence_name :block_catchup_sequencer defstruct blocks_batch_size: @blocks_batch_size, diff --git a/apps/indexer/lib/indexer/block/fetcher.ex b/apps/indexer/lib/indexer/block/fetcher.ex index 7f33f3ad520b..caf26e1dc422 100644 --- a/apps/indexer/lib/indexer/block/fetcher.ex +++ b/apps/indexer/lib/indexer/block/fetcher.ex @@ -71,7 +71,7 @@ defmodule Indexer.Block.Fetcher do # These are all the *default* values for options. # DO NOT use them directly in the code. Get options from `state`. - @receipts_batch_size 250 + @receipts_batch_size 50 @receipts_concurrency 10 @doc false diff --git a/apps/indexer/lib/indexer/fetcher/token_balance.ex b/apps/indexer/lib/indexer/fetcher/token_balance.ex index 9af2d7b34476..ae25d6a7b241 100644 --- a/apps/indexer/lib/indexer/fetcher/token_balance.ex +++ b/apps/indexer/lib/indexer/fetcher/token_balance.ex @@ -26,7 +26,7 @@ defmodule Indexer.Fetcher.TokenBalance do @defaults [ flush_interval: 300, - max_batch_size: 100, + max_batch_size: 50, max_concurrency: 10, task_supervisor: Indexer.Fetcher.TokenBalance.TaskSupervisor ] diff --git a/apps/indexer/lib/indexer/temporary/uncles_without_index.ex b/apps/indexer/lib/indexer/temporary/uncles_without_index.ex index 12f133ff1aff..3a3e821d6ecc 100644 --- a/apps/indexer/lib/indexer/temporary/uncles_without_index.ex +++ b/apps/indexer/lib/indexer/temporary/uncles_without_index.ex @@ -23,7 +23,7 @@ defmodule Indexer.Temporary.UnclesWithoutIndex do @defaults [ flush_interval: :timer.seconds(3), - max_batch_size: 100, + max_batch_size: 50, max_concurrency: 10, task_supervisor: Indexer.Temporary.UnclesWithoutIndex.TaskSupervisor, metadata: [fetcher: :uncles_without_index]