fix lint

python/pysrc/kaskada/sources/arrow.py

@@ -1,7 +1,6 @@
 """Provide sources based on PyArrow, including Pandas and CSV."""
 from __future__ import annotations
 
-import os
 from io import BytesIO
 from typing import Optional
 
@@ -309,6 +308,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."""
 
@@ -356,7 +356,7 @@ async def create(
         schema: Optional[pa.Schema] = None,
         grouping_name: Optional[str] = None,
         time_unit: Optional[TimeUnit] = None,
-    ) -> JsonlString:
+    ) -> JsonlFile:
         """Create a source reading a line-delimited JSON file.
 
         Args:
@@ -395,12 +395,13 @@ async def create(
 
     async def add_file(self, path: str) -> None:
         """Add data to the source."""
-        path = Source._get_absolute_path(path)
+        abs_path = Source._get_absolute_path(path)
 
-        batches = pa.json.read_json(path, parse_options=self._parse_options)
+        batches = pa.json.read_json(abs_path, parse_options=self._parse_options)
         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."""
 
@@ -558,7 +559,6 @@ async def create(
             time_unit: The unit of the time column. One of `ns`, `us`, `ms`, or `s`.
               If not specified (and not specified in the data), nanosecond will be assumed.
         """
-
         path = Source._get_absolute_path(path)
 
         if schema is None:
@@ -581,6 +581,6 @@ async def create(
 
     async def add_file(self, path: str) -> None:
         """Add data to the source."""
-        path = Source._get_absolute_path(path)
+        abs_path = Source._get_absolute_path(path)
 
-        await self._ffi_table.add_parquet(path)
+        await self._ffi_table.add_parquet(abs_path)

python/pysrc/kaskada/sources/source.py

@@ -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]) -> Optional[str]:
         if path is None or path.startswith("/"):
             return path
         return os.getcwd() + "/" + path