def METHOD_NAME() -> None:
    # Arrange
    provider = TestDataProvider()
    wrangler = TradeTickDataWrangler(instrument=ETHUSDT_BINANCE)
    ticks = wrangler.process(provider.read_csv_ticks("binance-ethusdt-trades.csv"))
    # Act
    batches_bytes = DataTransformer.pyobjects_to_batches_bytes(ticks)
    batches_stream = BytesIO(batches_bytes)
    reader = pa.ipc.open_stream(batches_stream)
    # Assert
    assert len(ticks) == 69_806
    assert len(reader.read_all()) == len(ticks)
    reader.close()