diff --git a/src/price_providers/dune_pricing.py b/src/price_providers/dune_pricing.py index 436bc4c..25d3098 100644 --- a/src/price_providers/dune_pricing.py +++ b/src/price_providers/dune_pricing.py @@ -3,6 +3,7 @@ from dune_client.types import QueryParameter from dune_client.client import DuneClient from dune_client.query import QueryBase +from dune_client.models import DuneError from src.helpers.config import get_web3_instance, get_logger from src.helpers.helper_functions import extract_params from src.constants import DUNE_PRICE_QUERY_ID, DUNE_QUERY_BUFFER_TIME @@ -51,7 +52,13 @@ def get_price(self, price_params: dict) -> float | None: ), ], ) - result = dune.run_query(query=query) # type: ignore[attr-defined] + try: + result = dune.run_query(query=query) # type: ignore[attr-defined] + except DuneError as e: + self.logger.warning( + f"Unable to run query, Dune returned with error {e}" + ) + return None if result.result.rows: row = result.result.rows[0] price = row.get("price")