Function _digest_frame

python/tests/test_data_module.py:16–19

(df: pl.DataFrame)

def _digest_frame(df: pl.DataFrame) -> str:
    normalized = df.with_columns(pl.col("ts").dt.strftime("%Y-%m-%d %H:%M:%S"))
    payload = json.dumps(normalized.to_dict(as_series=False), sort_keys=True, separators=(",", ":"))
    return hashlib.sha256(payload.encode("utf-8")).hexdigest()


def test_load_ohlcv_enforces_canonical_schema_and_determinism():