(df: pl.DataFrame)
| 212 | |
| 213 | |
| 214 | def data_quality_report(df: pl.DataFrame) -> dict[str, Any]: |
| 215 | sorted_df = ( |
| 216 | _prepare_ohlcv_lf(df) |
| 217 | .with_columns(pl.col("ts").dt.timestamp(time_unit="us").alias("ts_us")) |
| 218 | .sort(["symbol", "ts_us"]) |
| 219 | .collect() |
| 220 | ) |
| 221 | return _build_quality_report(sorted_df, rows_removed_by_deduplication=0) |
| 222 | |
| 223 | |
| 224 | def load_ohlcv( |
nothing calls this directly
no test coverage detected