Skip to content

Commit

Permalink
fix lint
Browse files Browse the repository at this point in the history
  • Loading branch information
epinzur committed Sep 26, 2023
1 parent 36d8f72 commit e5407ba
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 1 deletion.
2 changes: 2 additions & 0 deletions python/pysrc/kaskada/sources/arrow.py
Original file line number Diff line number Diff line change
Expand Up @@ -309,6 +309,7 @@ async def add_string(self, csv_string: str | BytesIO) -> None:
for batch in content.to_batches():
await self._ffi_table.add_pyarrow(batch)


class JsonlFile(Source):
"""Source reading data from line-delimited JSON files using PyArrow."""

Expand Down Expand Up @@ -401,6 +402,7 @@ async def add_file(self, path: str) -> None:
for batch in batches.to_batches():
await self._ffi_table.add_pyarrow(batch)


class JsonlString(Source):
"""Source reading data from line-delimited JSON strings using PyArrow."""

Expand Down
2 changes: 1 addition & 1 deletion python/pysrc/kaskada/sources/source.py
Original file line number Diff line number Diff line change
Expand Up @@ -92,7 +92,7 @@ def _validate_column(field_name: Optional[str], schema: pa.Schema) -> None:
raise ValueError(f"Column: {field_name!r} must be non-nullable")

@staticmethod
def _get_absolute_path(path: Optional[str]) -> str|None:
def _get_absolute_path(path: Optional[str]) -> str | None:
if path is None or path.startswith("/"):
return path
return os.getcwd() + "/" + path

0 comments on commit e5407ba

Please sign in to comment.