diff --git a/flytekit/core/data_persistence.py b/flytekit/core/data_persistence.py index af5593702b7..57311ed4157 100644 --- a/flytekit/core/data_persistence.py +++ b/flytekit/core/data_persistence.py @@ -119,6 +119,9 @@ def get_filesystem( if anonymous: kwargs["token"] = _ANON return fsspec.filesystem(protocol, **kwargs) # type: ignore + elif protocol == "abfs": + kwargs["anon"] = False + return fsspec.filesystem(protocol, **kwargs) # type: ignore # Preserve old behavior of returning None for file systems that don't have an explicit anonymous option. if anonymous: