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

…n to False (flyteorg#1813) Signed-off-by: Jan Fiedler <[email protected]> Signed-off-by: Future Outlier <[email protected]>
Future-Outlier · Oct 3, 2023 · 664ca67 · 664ca67
1 parent e6052de
commit 664ca67
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: