diff --git a/docs/integrations/tardis.md b/docs/integrations/tardis.md index 9ecf084ef45..e449196af3f 100644 --- a/docs/integrations/tardis.md +++ b/docs/integrations/tardis.md @@ -77,8 +77,9 @@ This includes the following: ## Symbology and normalization -The Tardis integration seamlessly integrates with NautilusTrader's crypto exchange adapters through consistent symbol normalization. -Each exchange's raw symbols are normalized to follow Nautilus symbology conventions as detailed below: +The Tardis integration ensures seamless compatibility with NautilusTrader’s crypto exchange adapters +by consistently normalizing symbols. Typically, NautilusTrader uses the native exchange naming conventions +provided by Tardis. However, for certain exchanges, raw symbols are adjusted to adhere to the Nautilus symbology normalization, as outlined below: ### Common rules @@ -91,6 +92,7 @@ Each exchange's raw symbols are normalized to follow Nautilus symbology conventi - **Binance**: Nautilus appends the suffix `-PERP` to all perpetual symbols. - **Bybit**: Nautilus uses specific product category suffixes, including `-SPOT`, `-LINEAR`, `-INVERSE`, `-OPTION`. - **dYdX**: Nautilus appends the suffix `-PERP` to all perpetual symbols. +- **Gate.io**: Nautilus appends the suffix `-PERP` to all perpetual symbols. For detailed symbology documentation per exchange: diff --git a/nautilus_core/adapters/src/tardis/parse.rs b/nautilus_core/adapters/src/tardis/parse.rs index 9b827d56bd2..a93c556b0b9 100644 --- a/nautilus_core/adapters/src/tardis/parse.rs +++ b/nautilus_core/adapters/src/tardis/parse.rs @@ -81,12 +81,6 @@ pub fn normalize_symbol_str( symbol.push_str("-PERP"); } - Exchange::HuobiDmSwap | Exchange::HuobiDmLinearSwap - if instrument_type == InstrumentType::Perpetual => - { - symbol.push_str("-PERP"); - } - _ => {} } diff --git a/nautilus_trader/adapters/tardis/data.py b/nautilus_trader/adapters/tardis/data.py index ef5ec16b9bb..9240461c61d 100644 --- a/nautilus_trader/adapters/tardis/data.py +++ b/nautilus_trader/adapters/tardis/data.py @@ -465,7 +465,7 @@ async def _request_bars( ), ) - self._log.info( + self._log.debug( f"Streamed {len(bar_capsules):,} {bar_type} bars from replay", LogColor.MAGENTA, ) @@ -482,7 +482,7 @@ async def _request_bars( and (end is None or bar.ts_event <= end) ] - self._log.info( + self._log.debug( f"Sending response with {len(bars):,} bars after filtering", LogColor.MAGENTA, )