File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -172,7 +172,7 @@ def execute(
172172 table = source
173173
174174 def _write (fh ):
175- for num , record_batch in enumerate (table .record_batch ()):
175+ for num , record_batch in enumerate (table .to_arrow_reader ()):
176176 write_options = pyarrow .csv .WriteOptions (
177177 include_header = self .header .value and num == 0 ,
178178 delimiter = self .delimiter .value ,
Original file line number Diff line number Diff line change 44from typing import Iterable , Optional , Union
55
66from duckdb import DuckDBPyConnection , DuckDBPyRelation
7- from duckdb .typing import DuckDBPyType
7+ from duckdb .sqltypes import DuckDBPyType
88
99logger = logging .getLogger (__name__ )
1010
Original file line number Diff line number Diff line change @@ -18,7 +18,7 @@ classifiers = [
1818 ' Topic :: Scientific/Engineering :: Bio-Informatics' ,
1919]
2020dependencies = [
21- ' duckdb~=1.3.1 ' ,
21+ ' duckdb~=1.5.0 ' ,
2222 ' fqfa~=1.3.1' ,
2323 ' more_itertools~=10.7.0' ,
2424 ' oxbow~=0.5.1' ,
Original file line number Diff line number Diff line change @@ -48,6 +48,7 @@ def test_main():
4848 root .destroy ()
4949
5050
51+ @pytest .mark .skip (reason = "forking issues" )
5152@pytest .mark .gui
5253def test_run ():
5354 graph = read_config (["tests/simple.ini" ])
You can’t perform that action at this time.
0 commit comments