Fix Arrow schema registration for BinanceBar

Author: cjdsellers

RELEASES.md

@@ -17,6 +17,7 @@ Released on TBD (UTC).
 ### Fixes
 - Fixed `generate_order_modify_rejected` typo in Binance execution client (#2682), thanks for reporting @etiennepar
 - Fixed order status report generation for Polymarket where `venue_order_id` was unbounded
+- Fixed Arrow schema registration for `BinanceBar`
 
 ### Documentation Updates
 None

nautilus_trader/adapters/binance/__init__.py

@@ -24,6 +24,8 @@
 ``nautilus_trader.adapters.binance``.
 
 """
+from typing import Final
+
 import pyarrow as pa
 
 from nautilus_trader.adapters.binance.common.constants import BINANCE
@@ -43,6 +45,7 @@
 from nautilus_trader.adapters.binance.spot.providers import BinanceSpotInstrumentProvider
 from nautilus_trader.serialization import register_serializable_type
 from nautilus_trader.serialization.arrow.schema import NAUTILUS_ARROW_SCHEMA
+from nautilus_trader.serialization.arrow.serializer import register_arrow
 
 
 register_serializable_type(
@@ -57,7 +60,7 @@
     BinanceTicker.from_dict,
 )
 
-NAUTILUS_ARROW_SCHEMA[BinanceBar] = pa.schema(
+BINANCE_BAR_ARROW_SCHEMA: Final[pa.schema] = pa.schema(
     {
         "bar_type": pa.dictionary(pa.int16(), pa.string()),
         "instrument_id": pa.dictionary(pa.int64(), pa.string()),
@@ -75,6 +78,10 @@
     },
 )
 
+NAUTILUS_ARROW_SCHEMA[BinanceBar] = BINANCE_BAR_ARROW_SCHEMA
+
+register_arrow(BinanceBar, BINANCE_BAR_ARROW_SCHEMA)
+
 __all__ = [
     "BINANCE",
     "BINANCE_CLIENT_ID",

nautilus_trader/serialization/arrow/serializer.py

@@ -214,7 +214,7 @@ def serialize(
                 return ArrowSerializer.rust_defined_to_record_batch([data], data_cls=data_cls)
             raise TypeError(
                 f"Cannot serialize object `{data_cls}`. Register a "
-                f"serialization method via `nautilus_trader.persistence.catalog.parquet.serializers.register_parquet()`",
+                f"serialization method via `nautilus_trader.serialization.arrow.serializer.register_arrow()`",
             )
 
         batch = delegate(data)
@@ -281,7 +281,7 @@ def deserialize(data_cls: type, batch: pa.RecordBatch | pa.Table) -> Data:
                 return ArrowSerializer._deserialize_rust(data_cls=data_cls, table=batch)
             raise TypeError(
                 f"Cannot deserialize object `{data_cls}`. Register a "
-                f"deserialization method via `arrow.serializer.register_parquet()`",
+                f"deserialization method via `nautilus_trader.serialization.arrow.serializer.register_arrow()`",
             )
 
         return delegate(batch)