(df: &DataFrame)
| 64 | } |
| 65 | |
| 66 | fn require_ohlcv_columns(df: &DataFrame) -> Result<(), String> { |
| 67 | for name in ["symbol", "ts_us", "open", "high", "low", "close", "volume", "adj_close"] { |
| 68 | df.column(name).map_err(|e| format!("missing required column '{name}': {e}"))?; |
| 69 | } |
| 70 | Ok(()) |
| 71 | } |
| 72 | |
| 73 | fn sort_ohlcv_df(df: &DataFrame) -> Result<DataFrame, String> { |
| 74 | df.sort( |
no outgoing calls
no test coverage detected