Improve logging for TardisInstrumentProvider

Author: cjdsellers

Diff for: nautilus_trader/adapters/tardis/providers.py

@@ -73,6 +73,7 @@ async def load_all_async(self, filters: dict | None = None) -> None:
         for venue in venues:
             venue = venue.upper().replace("-", "_")
             for exchange in nautilus_pyo3.tardis_exchange_from_venue_str(venue):
+                self._log.info(f"Requesting instruments for {exchange=}")
                 pyo3_instruments = await self._client.instruments(
                     exchange=exchange.lower(),
                     base_currency=list(base_currency) if base_currency else None,
@@ -121,6 +122,7 @@ async def load_ids_async(
         ts_init = time.time_ns()
 
         for exchange, symbols in venue_instruments.items():
+            self._log.info(f"Requesting instruments for {exchange=}")
             pyo3_instruments = await self._client.instruments(
                 exchange=exchange.lower(),
                 base_currency=list(base_currency) if base_currency else None,

Diff for: tests/integration_tests/adapters/tardis/sandbox/http_instruments.py

@@ -38,19 +38,16 @@ async def run():
         base_currency=["BTC"],
         quote_currency=["USD"],
         instrument_type=["perpetual"],
-        active=True,
+        # active=True,
         # start=pd.Timestamp("2021-01-01").value,
         # end=pd.Timestamp("2022-01-01").value,
         effective=pd.Timestamp("2020-08-01 08:00:00").value,
     )
 
-    for inst in pyo3_instruments:
-        print(inst.id)
-        print(
-            CryptoPerpetual.from_pyo3(inst),
-            pd.Timestamp(inst.ts_event),
-            pd.Timestamp(inst.ts_init),
-        )
+    for pyo3_inst in pyo3_instruments:
+        inst = CryptoPerpetual.from_pyo3(pyo3_inst)  # Remove/change this if not filtering for perps
+        print(repr(inst))
+        print(pd.Timestamp(inst.ts_event))
 
     print(f"Received: {len(pyo3_instruments)} instruments")
 

Diff for: tests/integration_tests/adapters/tardis/sandbox/instrument_provider.py

@@ -71,7 +71,7 @@ async def run():
             "venues": frozenset(exchanges),
             # "quote_currency": frozenset(["BTC"]),
             # "base_currency": frozenset(["USDC"]),
-            # "instrument_type": frozenset(["spot"]),
+            # "instrument_type": frozenset(["perpetual"]),
             # "start": pd.Timestamp("2021-01-01").value,
             # "end": pd.Timestamp("2023-01-01").value,
             # "effective": pd.Timestamp("2022-01-01").value,
@@ -96,7 +96,6 @@ async def run():
 
         for instrument in provider.list_all():
             print(instrument.id)
-            print(instrument.size_increment)
 
         count = len(provider.list_all())
         total_instrument_count += count