Skip to content

Commit 6346fc3

Browse files
committed
fix: also add abfss in get_filesystem
Signed-off-by: machichima <[email protected]>
1 parent 83f4db5 commit 6346fc3

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

flytekit/core/data_persistence.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -277,7 +277,7 @@ def get_filesystem(
277277
return fsspec.filesystem(protocol, **s3kwargs) # type: ignore
278278
elif protocol == "gs":
279279
return fsspec.filesystem(protocol, **kwargs) # type: ignore
280-
elif protocol == "abfs":
280+
elif protocol in ("abfs", "abfss"):
281281
azkwargs = azure_setup_args(self._data_config.azure, anonymous=anonymous, **kwargs)
282282
azkwargs.update(kwargs)
283283
return fsspec.filesystem(protocol, **azkwargs) # type: ignore

0 commit comments

Comments
 (0)