Merge pull request #78 from cowprotocol/block_range

use more optimistic block range for sync
cowprotocol · Feb 5, 2024 · 85611db · 85611db
2 parents f4e3e5c + 8fdeb14
commit 85611db
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/src/fetch/orderbook.py b/src/fetch/orderbook.py
@@ -15,7 +15,7 @@
 from src.models.block_range import BlockRange
 from src.utils import open_query
 
-REORG_THRESHOLD = 65
+MAX_PROCESSING_DELAY = 10
 
 
 class OrderbookEnv(Enum):
@@ -69,7 +69,9 @@ def get_latest_block(cls) -> int:
             open_query("orderbook/latest_block.sql"), data_types
         )
         assert len(barn) == 1 == len(prod), "Expecting single record"
-        return min(int(barn["latest"][0]), int(prod["latest"][0])) - REORG_THRESHOLD
+        return (
+            max(int(barn["latest"][0]), int(prod["latest"][0])) - MAX_PROCESSING_DELAY
+        )
 
     @classmethod
     def get_order_rewards(cls, block_range: BlockRange) -> DataFrame:

diff --git a/src/fetch/postgres.py b/src/fetch/postgres.py
@@ -7,10 +7,11 @@
 from sqlalchemy import create_engine
 from sqlalchemy.engine import Engine
 
-from src.fetch.orderbook import REORG_THRESHOLD
 from src.models.block_range import BlockRange
 from src.utils import open_query
 
+REORG_THRESHOLD = 65
+
 
 @dataclass
 class PostgresFetcher: