File tree Expand file tree Collapse file tree 2 files changed +6
-13
lines changed Expand file tree Collapse file tree 2 files changed +6
-13
lines changed Original file line number Diff line number Diff line change @@ -77,7 +77,6 @@ async def run(self):
77
77
coingecko_prices , coingecko_updates = await self .get_coingecko_prices ()
78
78
crosschain_prices = await self .get_crosschain_prices ()
79
79
80
- failed_checks = []
81
80
for product in products :
82
81
# Skip tombstone accounts with blank metadata
83
82
if "base" not in product .attrs :
@@ -160,16 +159,10 @@ async def run(self):
160
159
)
161
160
)
162
161
163
- cur_failed_checks = await self .dispatch .run (states )
164
- if cur_failed_checks :
165
- failed_checks .extend (cur_failed_checks )
162
+ await self .dispatch .run (states )
166
163
167
- if failed_checks :
168
- logger .error (f"Failed checks: { len (failed_checks )} " )
169
- else :
170
- logger .info ("All checks passed" )
171
164
logger .debug ("Sleeping..." )
172
- await asyncio .sleep (30 )
165
+ await asyncio .sleep (5 )
173
166
174
167
async def get_pyth_products (self ) -> List [PythProductAccount ]:
175
168
logger .debug ("Fetching Pyth product accounts..." )
Original file line number Diff line number Diff line change @@ -277,8 +277,8 @@ def error_message(self) -> dict:
277
277
278
278
279
279
PRICE_FEED_CHECKS = [
280
- # PriceFeedCoinGeckoCheck,
281
- # PriceFeedCrossChainDeviationCheck,
282
- # PriceFeedCrossChainOnlineCheck,
283
- # PriceFeedOfflineCheck,
280
+ PriceFeedCoinGeckoCheck ,
281
+ PriceFeedCrossChainDeviationCheck ,
282
+ PriceFeedCrossChainOnlineCheck ,
283
+ PriceFeedOfflineCheck ,
284
284
]
You can’t perform that action at this time.
0 commit comments