| 192 | } |
| 193 | |
| 194 | pub fn get_events<'py>( |
| 195 | &'py self, |
| 196 | query: Query, |
| 197 | py: Python<'py>, |
| 198 | ) -> PyResult<Bound<'py, PyAny>> { |
| 199 | let inner = Arc::clone(&self.inner); |
| 200 | |
| 201 | future_into_py(py, async move { |
| 202 | let query = query.try_convert().context("parse query")?; |
| 203 | |
| 204 | let res = inner.get_events(query).await.context("get arrow")?; |
| 205 | |
| 206 | let res = convert_event_response(res).context("convert response to pyarrow")?; |
| 207 | |
| 208 | Ok(res) |
| 209 | }) |
| 210 | } |
| 211 | |
| 212 | pub fn get_arrow<'py>(&'py self, query: Query, py: Python<'py>) -> PyResult<Bound<'py, PyAny>> { |
| 213 | let inner = Arc::clone(&self.inner); |