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

…n to False (flyteorg#1813) Signed-off-by: Jan Fiedler <jan.fiedler@kineo.ai>
hhcs9527 · Sep 9, 2023 · 0fc03c1 · 0fc03c1
1 parent 553820e
commit 0fc03c1
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: