Skip to content

Commit 90ea913

Browse files
committed
remove some debugging
Signed-off-by: Yee Hing Tong <[email protected]>
1 parent d70b528 commit 90ea913

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

flytekit/core/data_persistence.py

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -199,8 +199,7 @@ def get_filesystem(
199199
elif protocol == "s3":
200200
s3kwargs = s3_setup_args(self._data_config.s3, anonymous=anonymous)
201201
s3kwargs.update(kwargs)
202-
fs = fsspec.filesystem(protocol, **s3kwargs) # type: ignore
203-
return fs
202+
return fsspec.filesystem(protocol, **s3kwargs) # type: ignore
204203
elif protocol == "gs":
205204
if anonymous:
206205
kwargs["token"] = _ANON
@@ -221,8 +220,7 @@ async def get_async_filesystem_for_path(
221220
) -> Union[AsyncFileSystem, fsspec.AbstractFileSystem]:
222221
protocol = get_protocol(path)
223222
loop = asyncio.get_running_loop()
224-
fs = self.get_filesystem(protocol, anonymous=anonymous, path=path, asynchronous=True, loop=loop, **kwargs)
225-
return fs
223+
return self.get_filesystem(protocol, anonymous=anonymous, path=path, asynchronous=True, loop=loop, **kwargs)
226224

227225
def get_filesystem_for_path(self, path: str = "", anonymous: bool = False, **kwargs) -> fsspec.AbstractFileSystem:
228226
protocol = get_protocol(path)

0 commit comments

Comments
 (0)