Merge pull request #61 from skalenetwork/set-chunk-size

set chunk size to 2000 for events

Author: dmytrotkk

credit-distributor/config.toml.example

@@ -25,4 +25,5 @@ from_block = 5678
 
 [agent] # optional
 loop_sleep = 120 # optional
-exception_sleep = 10 # optional
+exception_sleep = 10 # optional
+events_chunk_size = 2000 # optional - block range size for event log queries

credit-distributor/src/configs.py

@@ -50,6 +50,7 @@ class Destination(BaseModel):
 class Agent(BaseModel):
     loop_sleep: int = 120
     exception_sleep: int = 10
+    events_chunk_size: int = 2000
 
 
 class General(BaseModel):

credit-distributor/src/main.py

@@ -88,7 +88,9 @@ def distribute_credits_for_source(
     from_block = state.from_blocks[source.name]
     logger.info(f'[{source.name}] Fetching events from block {from_block}')
     all_events = mainnet_cs.credit_station.get_payment_received_events(
-        from_block=from_block, schain_name=config.general.schain_name
+        from_block=from_block,
+        schain_name=config.general.schain_name,
+        chunk_size=config.agent.events_chunk_size,
     )
     for event in all_events:
         fulfill_payment(source, event, schain_cs)