@@ -85,9 +85,10 @@ async def load_all_async(self, filters: dict | None = None) -> None:
85
85
for venue in venues :
86
86
venue = venue .upper ().replace ("-" , "_" )
87
87
for exchange in nautilus_pyo3 .tardis_exchange_from_venue_str (venue ):
88
+ exchange = exchange .lower ().replace ("_" , "-" )
88
89
self ._log .info (f"Requesting instruments for { exchange = } " )
89
90
pyo3_instruments = await self ._client .instruments (
90
- exchange = exchange . lower () ,
91
+ exchange = exchange ,
91
92
base_currency = list (base_currency ) if base_currency else None ,
92
93
quote_currency = list (quote_currency ) if quote_currency else None ,
93
94
instrument_type = list (instrument_type ) if instrument_type else None ,
@@ -147,9 +148,10 @@ async def load_ids_async(
147
148
available_offset_ns = available_offset
148
149
149
150
for exchange , symbols in venue_instruments .items ():
151
+ exchange = exchange .lower ().replace ("_" , "-" )
150
152
self ._log .info (f"Requesting instruments for { exchange = } " )
151
153
pyo3_instruments = await self ._client .instruments (
152
- exchange = exchange . lower () ,
154
+ exchange = exchange ,
153
155
base_currency = list (base_currency ) if base_currency else None ,
154
156
quote_currency = list (quote_currency ) if quote_currency else None ,
155
157
instrument_type = list (instrument_type ) if instrument_type else None ,
0 commit comments