bugfix

earth-mover · Feb 25, 2025 · 5364104 · 5364104
1 parent cb2674f
commit 5364104
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/docs/docs/icechunk-python/parallel.md b/docs/docs/icechunk-python/parallel.md
@@ -127,8 +127,8 @@ with ProcessPoolExecutor() as executor:
             executor.submit(write_timestamp, itime=i, session=session)
             for i in range(ds.sizes["time"])
         ]
-    # grab the Session objects from each individual write task
-    sessions = [f.result() for f in futures]
+        # grab the Session objects from each individual write task
+        sessions = [f.result() for f in futures]
 
 # manually merge the remote sessions in to the local session
 session = merge_sessions(session, *sessions)

diff --git a/icechunk-python/examples/mpwrite.py b/icechunk-python/examples/mpwrite.py
@@ -1,3 +1,5 @@
+# An example of using multiprocessing to write to an Icechunk dataset
+
 import tempfile
 from concurrent.futures import ProcessPoolExecutor