diff --git a/cli.py b/cli.py index 4cbaeb0..140268e 100644 --- a/cli.py +++ b/cli.py @@ -108,7 +108,7 @@ def enqueue_many_blocks_command(after_block: int, before_block: int, batch_size: @cli.command() @coro -async def fetch_all_prices(): +def fetch_all_prices(): inspect_db_session = get_inspect_session() logger.info("Fetching prices") diff --git a/mev_inspect/prices.py b/mev_inspect/prices.py index 94816c6..af0eff3 100644 --- a/mev_inspect/prices.py +++ b/mev_inspect/prices.py @@ -3,7 +3,7 @@ from typing import List from pycoingecko import CoinGeckoAPI -from mev_inspect.schemas.prices import TOKEN_ADDRESSES, TOKEN_NAME_BY_ADDRESS, Price +from mev_inspect.schemas.prices import COINGECKO_ID_BY_ADDRESS, TOKEN_ADDRESSES, Price def fetch_prices() -> List[Price]: @@ -12,7 +12,7 @@ def fetch_prices() -> List[Price]: for token_address in TOKEN_ADDRESSES: price_data = cg.get_coin_market_chart_by_id( - id=TOKEN_NAME_BY_ADDRESS[token_address], vs_currency="usd", days="max" + id=COINGECKO_ID_BY_ADDRESS[token_address], vs_currency="usd", days="max" ) price_time_series = price_data["prices"] diff --git a/mev_inspect/schemas/prices.py b/mev_inspect/schemas/prices.py index 3b99ad1..e57987c 100644 --- a/mev_inspect/schemas/prices.py +++ b/mev_inspect/schemas/prices.py @@ -29,7 +29,7 @@ TOKEN_ADDRESSES = [ CDAI_TOKEN_ADDRESS, ] -TOKEN_NAME_BY_ADDRESS = { +COINGECKO_ID_BY_ADDRESS = { WETH_ADDRESS: "weth", ETH_TOKEN_ADDRESS: "ethereum", WBTC_TOKEN_ADDRESS: "wrapped-bitcoin",