Skip to content

Commit 0d2cde7

Browse files
authored
update param name on parquet source to match docs (#804)
1 parent d893f39 commit 0d2cde7

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

python/pysrc/kaskada/sources/arrow.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -539,7 +539,7 @@ def __init__(
539539

540540
@staticmethod
541541
async def create(
542-
url: Optional[str] = None,
542+
file: Optional[str] = None,
543543
*,
544544
time_column: str,
545545
key_column: str,
@@ -566,9 +566,9 @@ async def create(
566566
If not specified (and not specified in the data), nanosecond will be assumed.
567567
"""
568568
if schema is None:
569-
if url is None:
569+
if file is None:
570570
raise ValueError("Must provide schema or url to parquet file")
571-
schema = await _ffi.parquet_schema(_get_session(), url)
571+
schema = await _ffi.parquet_schema(_get_session(), file)
572572
source = Parquet(
573573
time_column=time_column,
574574
key_column=key_column,
@@ -578,8 +578,8 @@ async def create(
578578
time_unit=time_unit,
579579
)
580580

581-
if url:
582-
await source.add_file(url)
581+
if file:
582+
await source.add_file(file)
583583
return source
584584

585585
async def add_file(self, file: str) -> None:

0 commit comments

Comments
 (0)