diff --git a/python/pysrc/kaskada/sources/arrow.py b/python/pysrc/kaskada/sources/arrow.py
index bb9243195..4684a7124 100644
--- a/python/pysrc/kaskada/sources/arrow.py
+++ b/python/pysrc/kaskada/sources/arrow.py
@@ -539,7 +539,7 @@ def __init__(
 
     @staticmethod
     async def create(
-        url: Optional[str] = None,
+        file: Optional[str] = None,
         *,
         time_column: str,
         key_column: str,
@@ -566,9 +566,9 @@ async def create(
               If not specified (and not specified in the data), nanosecond will be assumed.
         """
         if schema is None:
-            if url is None:
+            if file is None:
                 raise ValueError("Must provide schema or url to parquet file")
-            schema = await _ffi.parquet_schema(_get_session(), url)
+            schema = await _ffi.parquet_schema(_get_session(), file)
         source = Parquet(
             time_column=time_column,
             key_column=key_column,
@@ -578,8 +578,8 @@ async def create(
             time_unit=time_unit,
         )
 
-        if url:
-            await source.add_file(url)
+        if file:
+            await source.add_file(file)
         return source
 
     async def add_file(self, file: str) -> None: