(
py: Python<'_>,
pydf: PyDataFrame,
dedupe_keep_last: bool,
)
| 124 | )) |
| 125 | } |
| 126 | |
| 127 | #[pyfunction(name = "clean_ohlcv_df")] |
| 128 | fn data_clean_ohlcv_df( |
| 129 | py: Python<'_>, |
| 130 | pydf: PyDataFrame, |
| 131 | dedupe_keep_last: bool, |
| 132 | ) -> PyResult<(PyDataFrame, PyObject)> { |
| 133 | let df: DataFrame = pydf.into(); |
| 134 | let (out_df, report) = |
| 135 | openquant::data_processing::clean_ohlcv_df(&df, dedupe_keep_last).map_err(to_py_err)?; |
| 136 | let out_report = report_to_pydict(py, report)?; |
| 137 | Ok((PyDataFrame(out_df), out_report)) |
| 138 | } |
| 139 |
nothing calls this directly
no test coverage detected