We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 016adc0 commit 03c5f78Copy full SHA for 03c5f78
connectorx-python/connectorx/__init__.py
@@ -442,7 +442,7 @@ def read_sql(
442
return df
443
444
445
-def reconstruct_arrow_rb(results) -> Iterator[pa.RecordBatch]:
+def reconstruct_arrow_rb(results) -> pa.RecordBatchReader:
446
import pyarrow as pa
447
448
# Get Schema
connectorx-python/src/arrow.rs
@@ -43,7 +43,6 @@ impl PyRecordBatch {
43
44
#[pymethods]
45
impl PyRecordBatchIterator {
46
-
47
#[throws(ConnectorXPythonError)]
48
fn schema_ptr<'py>(&self, py: Python<'py>) -> Bound<'py, PyAny> {
49
let (rb, _) = self.0.get_schema();
0 commit comments