11import asyncio
22import time
3- from typing import List , Optional , Any
3+ from typing import Any , List , Optional
44
55from aiohttp import ClientSession
66
77from pragma_sdk .common .configs .asset_config import AssetConfig
8- from pragma_sdk .common .types .currency import Currency
9- from pragma_sdk .common .types .entry import Entry , SpotEntry
10- from pragma_sdk .common .types .pair import Pair
118from pragma_sdk .common .exceptions import PublisherFetchError
12- from pragma_sdk .common .fetchers .interface import FetcherInterfaceT
139from pragma_sdk .common .fetchers .handlers .hop_handler import HopHandler
10+ from pragma_sdk .common .fetchers .interface import FetcherInterfaceT
1411from pragma_sdk .common .logging import get_pragma_sdk_logger
12+ from pragma_sdk .common .types .currency import Currency
13+ from pragma_sdk .common .types .entry import Entry , SpotEntry
14+ from pragma_sdk .common .types .pair import Pair
1515
1616logger = get_pragma_sdk_logger ()
1717
@@ -20,6 +20,9 @@ class GateioFetcher(FetcherInterfaceT):
2020 BASE_URL : str = "https://api.gateio.ws/api/v4/spot/tickers"
2121 SOURCE : str = "GATEIO"
2222
23+ # Pairs to skip fetching from GateIO
24+ SKIP_PAIRS : set = {"NSTR/USD" }
25+
2326 hop_handler = HopHandler (
2427 hopped_currencies = {
2528 "USD" : "USDT" ,
@@ -45,6 +48,8 @@ async def fetch(
4548 entries = []
4649 usdt_price = await self .get_stable_price ("USDT" )
4750 for pair in self .pairs :
51+ if str (pair ) in self .SKIP_PAIRS :
52+ continue
4853 entries .append (
4954 asyncio .ensure_future (self .fetch_pair (pair , session , usdt_price ))
5055 )
0 commit comments