✨ bump version to 2.8.11 (#275)

* feat: health endpoint

* ✨ bump version to 2.8.11

---------

Co-authored-by: Yasser Tahiri <yasserth19@gmail.com>

Author: EvolveArt

checkpointer/checkpointer/__init__.py

@@ -1 +1 @@
-__version__ = "2.8.10"
+__version__ = "2.8.11"

checkpointer/uv.lock

@@ -1 +1 @@
-__version__ = "2.8.10"
+__version__ = "2.8.11"

lmax-connector/lmax_connector/__init__.py

@@ -1 +1 @@
-__version__ = "2.8.10"
+__version__ = "2.8.11"

lp-pricer/uv.lock

@@ -1 +1 @@
-__version__ = "2.8.10"
+__version__ = "2.8.11"

pragma-sdk/pragma_sdk/__init__.py

@@ -1 +1 @@
-__version__ = "2.8.10"
+__version__ = "2.8.11"

pragma-sdk/uv.lock

@@ -1,7 +1,7 @@
 import asyncio
 import time
 import logging
-from typing import List, Optional, Dict
+from typing import List, Optional, Dict, Callable
 from starknet_py.contract import InvokeResult
 from starknet_py.net.client_errors import ClientError
 from requests.exceptions import RequestException
@@ -30,10 +30,15 @@ async def update_price_feeds(self, entries: List[Entry]) -> Optional[Dict]: ...
 
 
 class PricePusher(IPricePusher):
-    def __init__(self, client: PragmaClient):
+    def __init__(
+        self,
+        client: PragmaClient,
+        on_successful_push: Optional[Callable[[], None]] = None,
+    ):
         self.client = client
         self.consecutive_push_error = 0
         self.onchain_lock = asyncio.Lock()
+        self.on_successful_push = on_successful_push
 
         # Setup RPC health monitoring if using onchain client
         if isinstance(self.client, PragmaOnChainClient):
@@ -82,6 +87,11 @@ async def update_price_feeds(self, entries: List[Entry]) -> Optional[Dict]:
                 f"(took {(end_t - start_t):.2f}s)"
             )
             self.consecutive_push_error = 0
+
+            # Notify health server of successful push
+            if self.on_successful_push:
+                self.on_successful_push()
+
             return response
 
         except (ClientError, RequestException) as e: