diff --git a/project-db/spid/store.py b/project-db/spid/store.py index 9b2d7d1..5265333 100644 --- a/project-db/spid/store.py +++ b/project-db/spid/store.py @@ -186,7 +186,9 @@ class Store: sql += " ORDER BY filing_date" if limit: sql += f" LIMIT {int(limit)}" - return self.con.execute(sql).fetch_arrow_table().to_pylist() + res = self.con.execute(sql) + table = res.to_arrow_table() if hasattr(res, "to_arrow_table") else res.fetch_arrow_table() # DuckDB >= 2.0 / < 2.0 + return table.to_pylist() # ---- write side --------------------------------------------------- def upsert_mentions(self, mentions: list[ProjectMention], ctx: dict) -> int: