From 70425c87474b197974fec84a6c40066a15d2740f Mon Sep 17 00:00:00 2001 From: stevenhsd <56357022+stevenhsd@users.noreply.github.com> Date: Fri, 27 Feb 2026 16:25:25 +0000 Subject: [PATCH] fix: amend arrow file read to use streams --- .../backends/implementations/duckdb/reference_data.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/dve/core_engine/backends/implementations/duckdb/reference_data.py b/src/dve/core_engine/backends/implementations/duckdb/reference_data.py index c10aed7..af815ce 100644 --- a/src/dve/core_engine/backends/implementations/duckdb/reference_data.py +++ b/src/dve/core_engine/backends/implementations/duckdb/reference_data.py @@ -46,4 +46,4 @@ def load_parquet_file(self, uri: str) -> DuckDBPyRelation: @mark_refdata_file_extension("arrow") def load_arrow_file(self, uri: str) -> DuckDBPyRelation: """Load an arrow ipc file into a duckdb relation""" - return self.connection.from_arrow(ipc.open_file(uri).read_all()) # type:ignore + return self.connection.from_arrow(ipc.open_stream(uri).read_all()) # type:ignore