catch abfs protocol in data_persistence.py/get_filesystem and set ano…

…n to False Signed-off-by: Jan Fiedler <[email protected]>
flyteorg · Aug 31, 2023 · 3e30a68 · 3e30a68
1 parent 25f9863
commit 3e30a68
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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: