fix precommit

Author: bplatak

pyproject.toml

@@ -4,7 +4,7 @@ ignore_missing_imports = true
 
 [tool.poetry]
 name = "pyth-observer"
-version = "0.3.5"
+version = "2.1.4"
 description = "Alerts and stuff"
 authors = []
 readme = "README.md"

pyth_observer/__init__.py

@@ -17,14 +17,14 @@
 )
 from throttler import Throttler
 
+import pyth_observer.health_server as health_server
 from pyth_observer.check.price_feed import PriceFeedState
 from pyth_observer.check.publisher import PublisherState
 from pyth_observer.coingecko import Symbol, get_coingecko_prices
 from pyth_observer.crosschain import CrosschainPrice
 from pyth_observer.crosschain import CrosschainPriceObserver as Crosschain
 from pyth_observer.dispatch import Dispatch
 from pyth_observer.models import Publisher
-import pyth_observer.health_server as health_server
 
 PYTHTEST_HTTP_ENDPOINT = "https://api.pythtest.pyth.network/"
 PYTHTEST_WS_ENDPOINT = "wss://api.pythtest.pyth.network/"
@@ -133,7 +133,9 @@ async def run(self):
                                 latest_trading_slot=price_account.last_slot,
                                 price_aggregate=price_account.aggregate_price_info.price,
                                 confidence_interval_aggregate=price_account.aggregate_price_info.confidence_interval,
-                                coingecko_price=coingecko_prices.get(product.attrs["base"]),
+                                coingecko_price=coingecko_prices.get(
+                                    product.attrs["base"]
+                                ),
                                 coingecko_update=coingecko_updates.get(
                                     product.attrs["base"]
                                 ),

pyth_observer/cli.py

@@ -8,8 +8,8 @@
 from prometheus_client import start_http_server
 
 from pyth_observer import Observer, Publisher
-from pyth_observer.models import ContactInfo
 from pyth_observer.health_server import start_health_server
+from pyth_observer.models import ContactInfo
 
 
 @click.command()
@@ -63,7 +63,7 @@ def run(config, publishers, coingecko_mapping, prometheus_port):
     start_http_server(int(prometheus_port))
 
     async def main():
-        health_task = asyncio.create_task(start_health_server())
+        asyncio.create_task(start_health_server())
         await observer.run()
 
     asyncio.run(main())

pyth_observer/health_server.py

@@ -1,17 +1,21 @@
 import asyncio
+
 from aiohttp import web
 
 observer_ready = False
 
+
 async def live_handler(request):
     return web.Response(text="OK")
 
+
 async def ready_handler(request):
     if observer_ready:
         return web.Response(text="OK")
     else:
         return web.Response(status=503, text="Not Ready")
 
+
 async def start_health_server(port=8080):
     app = web.Application()
     app.router.add_get("/live", live_handler)
@@ -22,4 +26,3 @@ async def start_health_server(port=8080):
     await site.start()
     while True:
         await asyncio.sleep(3600)
-