Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
cctdaniel committed May 23, 2024
1 parent 1ce4960 commit 10fc97a
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 6 deletions.
3 changes: 2 additions & 1 deletion pyth_observer/dispatch.py
Original file line number Diff line number Diff line change
Expand Up @@ -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] = []
Expand Down
10 changes: 5 additions & 5 deletions sample.config.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -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:
Expand All @@ -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

0 comments on commit 10fc97a

Please sign in to comment.