wbt 0.1.7

Weight-based backtesting engine for quantitative trading
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

from __future__ import annotations

import pandas as pd

from wbt._df_convert import arrow_bytes_to_pd_df, pandas_to_arrow_bytes


class TestRoundTrip:
    """验证 Arrow 序列化/反序列化的往返一致性。"""

    def test_basic_roundtrip(self) -> None:
        """基础类型列（int, float, str）的完整往返。"""
        df = pd.DataFrame({"a": [1, 2, 3], "b": [1.1, 2.2, 3.3], "c": ["x", "y", "z"]})
        result = arrow_bytes_to_pd_df(pandas_to_arrow_bytes(df))
        pd.testing.assert_frame_equal(result, df)

    def test_datetime_roundtrip(self) -> None:
        """datetime 列应保留时间类型。"""
        df = pd.DataFrame({"dt": pd.to_datetime(["2024-01-01", "2024-01-02"]), "v": [1.0, 2.0]})
        result = arrow_bytes_to_pd_df(pandas_to_arrow_bytes(df))
        assert "datetime" in str(result["dt"].dtype)
        assert len(result) == 2

    def test_empty_dataframe(self) -> None:
        """空 DataFrame 应保留列名。"""
        df = pd.DataFrame({"a": pd.Series([], dtype="float64")})
        result = arrow_bytes_to_pd_df(pandas_to_arrow_bytes(df))
        assert len(result) == 0
        assert "a" in result.columns

    def test_series_input(self) -> None:
        """Series 转 DataFrame 后的往返。"""
        s = pd.Series([1.0, 2.0, 3.0], name="values")
        data = pandas_to_arrow_bytes(s.to_frame())
        result = arrow_bytes_to_pd_df(data)
        assert len(result) == 3
        assert "values" in result.columns