tmp

fsspec · Sep 26, 2024 · 6037c66 · 6037c66
1 parent b06276c
commit 6037c66
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 5 deletions.
diff --git a/fsspec/implementations/reference.py b/fsspec/implementations/reference.py
@@ -499,6 +499,7 @@ def write(self, field, record, base_url=None, storage_options=None):
             index=False,
             **df_backend_kwargs,
         )
+
         partition.clear()
         self._items.pop((field, record))
 

diff --git a/fsspec/implementations/tests/test_reference.py b/fsspec/implementations/tests/test_reference.py
@@ -773,12 +773,12 @@ def test_deep_parq(m, engine):
     )
     g = zarr.open_group(lz, mode="w")
 
-    # g2 = g.create_group("instant")
-    # g2.create_dataset(name="one", data=[1, 2, 3])
-    # lz.flush()
+    g2 = g.create_group("instant")
+    g2.create_dataset(name="one", data=[1, 2, 3])
+    lz.flush()
 
-    # # lz = fsspec.implementations.reference.LazyReferenceMapper("memory://out.parq", fs=m)
-    # # g = zarr.open_group(lz)
+    lz = fsspec.implementations.reference.LazyReferenceMapper("memory://out.parq", fs=m, engine=engine)
+    g = zarr.open_group(lz)
     # # assert g.instant.one[:].tolist() == [1, 2, 3]
     # # assert sorted(_["name"] for _ in lz.ls("")) == [".zgroup", ".zmetadata", "instant"]
     # # assert sorted(_["name"] for _ in lz.ls("instant")) == [