Skip to content

Commit b4661bb

Browse files
authored
Df nosync (#1157)
* missing character * remove async fail for df
1 parent e3c1a07 commit b4661bb

File tree

1 file changed

+1
-6
lines changed

1 file changed

+1
-6
lines changed

fsspec/implementations/reference.py

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
except ImportError:
1414
import json
1515

16-
from ..asyn import AsyncFileSystem, running_async
16+
from ..asyn import AsyncFileSystem
1717
from ..callbacks import _DEFAULT_CALLBACK
1818
from ..core import filesystem, open, split_protocol
1919
from ..spec import AbstractFileSystem
@@ -711,11 +711,6 @@ def _reference_part(self, part="metadata"):
711711
if part != "metadata" and part not in self.dirs:
712712
raise FileNotFoundError(f"prefix {part}")
713713
if part not in self.dataframes:
714-
if running_async():
715-
raise RuntimeError(
716-
"Cannot load references in async context, because"
717-
"load may trigger nested async operations"
718-
)
719714
url = f"{self.fo}/{part}.parq" if self.lazy else self.fo
720715
fs, path = fsspec.core.url_to_fs(url, **self.target_options)
721716
pf = fastparquet.ParquetFile(path, fs=fs)

0 commit comments

Comments
 (0)