diff --git a/pyth_observer/dispatch.py b/pyth_observer/dispatch.py index 7038362..9b93933 100644 --- a/pyth_observer/dispatch.py +++ b/pyth_observer/dispatch.py @@ -97,7 +97,8 @@ async def run(self, states: List[State]): sent_events.append(event.send()) await asyncio.gather(*sent_events) - await self.process_zenduty_events(current_time) + if "ZendutyEvent" in self.config["events"]: + await self.process_zenduty_events(current_time) def check_price_feed(self, state: PriceFeedState) -> List[Check]: failed_checks: List[Check] = [] diff --git a/sample.config.yaml b/sample.config.yaml index 9df7c4b..d960629 100644 --- a/sample.config.yaml +++ b/sample.config.yaml @@ -45,9 +45,9 @@ checks: max_slot_distance: 25 max_aggregate_distance: 6 PublisherStalledCheck: - enable: true - stall_time_limit: 30000000 # arbitrary large number to "disable" this check while allowing per feed config to override - abandoned_time_limit: 30000000 # arbitrary large number to "disable" this check while allowing per feed config to override + enable: false + stall_time_limit: 30 + abandoned_time_limit: 600 max_slot_distance: 25 # Per-symbol config Crypto.MNGO/USD: @@ -58,5 +58,5 @@ checks: max_slot_distance: 10000 Crypto.BTC/USD: PublisherStalledCheck: - stall_time_limit: 30 # This will override the global stall_time_limit for Crypto.BTC/USD - abandoned_time_limit: 600 # 10 minutes + enable: true + stall_time_limit: 60