fix: nonce error (#283)

JordyRo1 · EvolveArt · web-flow · commit 30b1d10d9197 · 2025-11-22T18:25:58.000Z
* fix: sleep

* fix: more conservative

* fix some stuff

* bump

---------

Co-authored-by: 0xevolve &lt;Artevolve@yahoo.com&gt;
diff --git a/checkpointer/checkpointer/__init__.py b/checkpointer/checkpointer/__init__.py
@@ -1 +1 @@
-__version__ = "2.10.1"
+__version__ = "2.10.2"
diff --git a/lmax-connector/lmax_connector/__init__.py b/lmax-connector/lmax_connector/__init__.py
@@ -1 +1 @@
-__version__ = "2.10.1"
+__version__ = "2.10.2"
diff --git a/pragma-sdk/pragma_sdk/__init__.py b/pragma-sdk/pragma_sdk/__init__.py
@@ -1 +1 @@
-__version__ = "2.10.1"
+__version__ = "2.10.2"
diff --git a/pragma-sdk/pragma_sdk/common/fetchers/fetchers/erc4626.py b/pragma-sdk/pragma_sdk/common/fetchers/fetchers/erc4626.py
@@ -23,7 +23,6 @@
     "https://ethereum.publicnode.com",
     "https://eth.llamarpc.com",
     "https://rpc.mevblocker.io",
-    "https://1rpc.io/eth",
     "https://eth.merkle.io",
     "https://rpc.flashbots.net",
 )
diff --git a/pragma-sdk/pragma_sdk/onchain/client.py b/pragma-sdk/pragma_sdk/onchain/client.py
@@ -25,7 +25,6 @@
     PublishEntriesOnChainResult,
 )
 from pragma_sdk.onchain.mixins import (
-    NonceMixin,
     OracleMixin,
     PublisherRegistryMixin,
     RandomnessMixin,
@@ -40,7 +39,6 @@
 
 class PragmaOnChainClient(  # type: ignore[misc]
     PragmaClient,
-    NonceMixin,
     OracleMixin,
     PublisherRegistryMixin,
     RandomnessMixin,
diff --git a/pragma-sdk/pragma_sdk/onchain/mixins/__init__.py b/pragma-sdk/pragma_sdk/onchain/mixins/__init__.py
@@ -1,12 +1,10 @@
-from pragma_sdk.onchain.mixins.nonce import NonceMixin
 from pragma_sdk.onchain.mixins.oracle import OracleMixin
 from pragma_sdk.onchain.mixins.publisher_registry import PublisherRegistryMixin
 from pragma_sdk.onchain.mixins.randomness import RandomnessMixin
 from pragma_sdk.onchain.mixins.summary import SummaryStatsMixin
 from pragma_sdk.onchain.mixins.merkle_feed import MerkleFeedMixin
 
 __all__ = [
-    "NonceMixin",
     "OracleMixin",
     "PublisherRegistryMixin",
     "RandomnessMixin",
diff --git a/pragma-sdk/pragma_sdk/onchain/mixins/nonce.py b/pragma-sdk/pragma_sdk/onchain/mixins/nonce.py
diff --git a/pragma-sdk/pragma_sdk/onchain/mixins/oracle.py b/pragma-sdk/pragma_sdk/onchain/mixins/oracle.py
@@ -1,3 +1,4 @@
+import asyncio
 import time
 from typing import Callable, Coroutine, Dict, List, Optional, Sequence
 
@@ -120,6 +121,8 @@ async def _publish_entries(
                 invocation = await self._invoke_publish(entries_subset, data_type)
                 invocations.append(invocation)
                 self._log_transaction(invocation, len(entries_subset), data_type)
+                if i + pagination < len(serialized_entries):
+                    await asyncio.sleep(0.5)
         else:
             invocation = await self._invoke_publish(serialized_entries, data_type)
             invocations.append(invocation)
diff --git a/pragma-utils/pragma_utils/__init__.py b/pragma-utils/pragma_utils/__init__.py
@@ -1 +1 @@
-__version__ = "2.10.1"
+__version__ = "2.10.2"
diff --git a/price-pusher/config/config.example.yaml b/price-pusher/config/config.example.yaml
@@ -1,5 +1,5 @@
 - pairs:
     spot:
-      - XSTRK/USD
+      - STRK/USD
   time_difference: 60
   price_deviation: 0.025
diff --git a/price-pusher/price_pusher/__init__.py b/price-pusher/price_pusher/__init__.py
@@ -1 +1 @@
-__version__ = "2.10.1"
+__version__ = "2.10.2"
diff --git a/price-pusher/price_pusher/core/fetchers.py b/price-pusher/price_pusher/core/fetchers.py
@@ -1,3 +1,4 @@
+import asyncio
 import logging
 import os
 
@@ -21,7 +22,7 @@
 logger = logging.getLogger(__name__)
 
 
-def add_all_fetchers(
+async def add_all_fetchers(
     fetcher_client: FetcherClient,
     publisher_name: str,
     price_configs: List[PriceConfig],
@@ -47,43 +48,41 @@ def add_all_fetchers(
         publisher_name,
         evm_rpc_urls,
     )
-    _add_fetchers(
-        fetcher_client,
-        ALL_FUTURE_FETCHERS,
-        future_pairs,
-        publisher_name,
-        evm_rpc_urls,
-    )
+
     return fetcher_client
 
 
-def _add_fetchers(
+async def _add_fetchers(
     fetcher_client: FetcherClient,
     fetchers: List[FetcherInterfaceT],
     pairs: Set[Pair],
     publisher_name: str,
     evm_rpc_urls: Optional[Sequence[str]],
 ) -> None:
     """
-    Add multiple fetchers to the FetcherClient.
+    Add multiple fetchers to the FetcherClient concurrently.
 
     Args:
         fetcher_client: The FetcherClient to add fetchers to.
         fetchers: List of fetcher classes to instantiate and add.
         pairs: List of pairs for the fetchers.
         publisher_name: The name of the publisher.
     """
-    for fetcher in fetchers:
-        _add_one_fetcher(
-            fetcher=fetcher,
-            fetcher_client=fetcher_client,
-            pairs=pairs,
-            publisher_name=publisher_name,
-            evm_rpc_urls=evm_rpc_urls,
-        )
+    await asyncio.gather(
+        *[
+            _add_one_fetcher(
+                fetcher=fetcher,
+                fetcher_client=fetcher_client,
+                pairs=pairs,
+                publisher_name=publisher_name,
+                evm_rpc_urls=evm_rpc_urls,
+            )
+            for fetcher in fetchers
+        ]
+    )
 
 
-def _add_one_fetcher(
+async def _add_one_fetcher(
     fetcher: FetcherInterfaceT,
     fetcher_client: FetcherClient,
     pairs: Set[Pair],
diff --git a/price-pusher/price_pusher/core/pusher.py b/price-pusher/price_pusher/core/pusher.py
@@ -84,6 +84,7 @@ async def update_price_feeds(self, entries: List[Entry]) -> Optional[Dict]:
                 f"🏋️ PUSHER: ✅ Successfully published {len(entries)} entrie(s)! "
                 f"(took {(end_t - start_t):.2f}s)"
             )
+            await asyncio.sleep(5)
             self.consecutive_push_error = 0
 
             # Notify health server of successful push
diff --git a/price-pusher/price_pusher/main.py b/price-pusher/price_pusher/main.py
@@ -63,7 +63,7 @@ async def main(
     )
 
     logger.info("🪚 Creating Fetcher client & adding fetchers...")
-    fetcher_client = add_all_fetchers(
+    fetcher_client = await add_all_fetchers(
         fetcher_client=FetcherClient(),
         publisher_name=publisher_name,
         price_configs=price_configs,
diff --git a/price-pusher/uv.lock b/price-pusher/uv.lock
diff --git a/vrf-listener/vrf_listener/__init__.py b/vrf-listener/vrf_listener/__init__.py

Original file line number	Diff line number	Diff line change
`@@ -1 +1 @@`
`1`		`-__version__ = "2.10.1"`
	`1`	`+__version__ = "2.10.2"`
Original file line number	Diff line number	Diff line change
`@@ -23,7 +23,6 @@`
`23`	`23`	`"https://ethereum.publicnode.com",`
`24`	`24`	`"https://eth.llamarpc.com",`
`25`	`25`	`"https://rpc.mevblocker.io",`
`26`		`- "https://1rpc.io/eth",`
`27`	`26`	`"https://eth.merkle.io",`
`28`	`27`	`"https://rpc.flashbots.net",`
`29`	`28`	`)`