cleanup

Author: bplatak

pyth_observer/__init__.py

@@ -77,8 +77,6 @@ def __init__(
             config=config,
         )
 
-        metrics.observer_up = 1
-
     async def run(self):
         # global states
         states = []
@@ -91,7 +89,6 @@ async def run(self):
                 crosschain_prices = await self.get_crosschain_prices()
 
                 health_server.observer_ready = True
-                metrics.observer_ready = 1
 
                 processed_feeds = 0
                 active_publishers_by_symbol = {}
@@ -205,10 +202,7 @@ async def run(self):
             except Exception as e:
                 logger.error(f"Error in run loop: {e}")
                 health_server.observer_ready = False
-                metrics.observer_ready = 0
                 metrics.loop_errors_total.labels(error_type=type(e).__name__).inc()
-
-                metrics.observer_ready = 0
             await asyncio.sleep(5)
 
     async def get_pyth_products(self) -> List[PythProductAccount]:

pyth_observer/metrics.py

@@ -13,8 +13,6 @@
 
 
 class PythObserverMetrics:
-    observer_ready = Gauge("pyth_observer_up", "Pyth observer is up")
-
     def __init__(self, registry: CollectorRegistry = REGISTRY):
         self.registry = registry
 
@@ -150,9 +148,6 @@ def __init__(self, registry: CollectorRegistry = REGISTRY):
             registry=registry,
         )
 
-        self.observer_up = 1
-        self.observer_ready = 0
-
     def set_observer_info(self, network: str, config: Dict[str, Any]):
         """Set static information about the observer instance."""
         self.observer_info.info(