Skip to content

Commit 9a641f8

Browse files
committed
refactor(api)!: align signatures of to_csv/to_csv_dir methods
1 parent f099499 commit 9a641f8

File tree

3 files changed

+5
-4
lines changed

3 files changed

+5
-4
lines changed

ibis/backends/__init__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -518,6 +518,7 @@ def to_parquet_dir(
518518
def to_csv(
519519
self,
520520
expr: ir.Table,
521+
/,
521522
path: str | Path,
522523
*,
523524
params: Mapping[ir.Scalar, Any] | None = None,
@@ -540,7 +541,6 @@ def to_csv(
540541
Additional keyword arguments passed to pyarrow.csv.CSVWriter
541542
542543
https://arrow.apache.org/docs/python/generated/pyarrow.csv.CSVWriter.html
543-
544544
"""
545545
self._import_pyarrow()
546546
import pyarrow.csv as pcsv

ibis/backends/duckdb/__init__.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1444,6 +1444,7 @@ def to_parquet(
14441444
def to_csv(
14451445
self,
14461446
expr: ir.Table,
1447+
/,
14471448
path: str | Path,
14481449
*,
14491450
params: Mapping[ir.Scalar, Any] | None = None,
@@ -1465,9 +1466,8 @@ def to_csv(
14651466
Mapping of scalar parameter expressions to value.
14661467
header
14671468
Whether to write the column names as the first line of the CSV file.
1468-
**kwargs
1469+
kwargs
14691470
DuckDB CSV writer arguments. https://duckdb.org/docs/data/csv/overview.html#parameters
1470-
14711471
"""
14721472
self._run_pre_execute_hooks(expr)
14731473
query = self.compile(expr, params=params)

ibis/expr/types/core.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -733,6 +733,7 @@ def to_parquet_dir(
733733
def to_csv(
734734
self,
735735
path: str | Path,
736+
/,
736737
*,
737738
params: Mapping[ir.Scalar, Any] | None = None,
738739
**kwargs: Any,
@@ -753,7 +754,7 @@ def to_csv(
753754
**kwargs
754755
Additional keyword arguments passed to pyarrow.csv.CSVWriter
755756
"""
756-
self._find_backend(use_default=True).to_csv(self, path, **kwargs)
757+
self._find_backend(use_default=True).to_csv(self, path, params=params, **kwargs)
757758

758759
@experimental
759760
def to_delta(

0 commit comments

Comments
 (0)