We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b00658e commit d1109acCopy full SHA for d1109ac
chain/ethereum/src/chain.rs
@@ -204,6 +204,12 @@ impl BlockStreamBuilder<Chain> for EthereumStreamBuilder {
204
),
205
};
206
207
+ let max_block_range_size = if is_using_subgraph_composition {
208
+ ENV_VARS.max_block_range_size * 10
209
+ } else {
210
+ ENV_VARS.max_block_range_size
211
+ };
212
+
213
Ok(Box::new(PollingBlockStream::new(
214
chain_store,
215
chain_head_update_stream,
@@ -214,7 +220,7 @@ impl BlockStreamBuilder<Chain> for EthereumStreamBuilder {
220
start_blocks,
221
reorg_threshold,
216
222
logger,
217
- ENV_VARS.max_block_range_size,
223
+ max_block_range_size,
218
224
ENV_VARS.target_triggers_per_block_range,
219
225
unified_api_version,
226
subgraph_current_block,
0 commit comments