Skip to content

Commit 935b831

Browse files
committed
add comment and revert newline
Signed-off-by: Yee Hing Tong <[email protected]>
1 parent 90ea913 commit 935b831

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

flytekit/core/data_persistence.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -220,6 +220,7 @@ async def get_async_filesystem_for_path(
220220
) -> Union[AsyncFileSystem, fsspec.AbstractFileSystem]:
221221
protocol = get_protocol(path)
222222
loop = asyncio.get_running_loop()
223+
223224
return self.get_filesystem(protocol, anonymous=anonymous, path=path, asynchronous=True, loop=loop, **kwargs)
224225

225226
def get_filesystem_for_path(self, path: str = "", anonymous: bool = False, **kwargs) -> fsspec.AbstractFileSystem:
@@ -422,6 +423,8 @@ async def async_put_raw_data(
422423
r = await self._put(from_path, to_path, **kwargs)
423424
return r or to_path
424425

426+
# See https://github.com/fsspec/s3fs/issues/871 for more background and pending work on the fsspec side to
427+
# support effectively async open(). For now these use-cases below will revert to sync calls.
425428
# raw bytes
426429
if isinstance(lpath, bytes):
427430
fs = self.get_filesystem_for_path(to_path)

0 commit comments

Comments
 (0)