diff --git a/python/pysrc/kaskada/sources/source.py b/python/pysrc/kaskada/sources/source.py index e07277730..92dd24cda 100644 --- a/python/pysrc/kaskada/sources/source.py +++ b/python/pysrc/kaskada/sources/source.py @@ -93,6 +93,6 @@ def _validate_column(field_name: Optional[str], schema: pa.Schema) -> None: @staticmethod def _get_absolute_path(path: Optional[str]) -> Optional[str]: - if path is None or path.startswith("/"): + if path is None or os.path.isabs(path): return path - return os.getcwd() + "/" + path + return os.path.abspath(path)