diff --git a/docs/docs/icechunk-python/parallel.md b/docs/docs/icechunk-python/parallel.md
index 7dad4a06..ad9073ab 100644
--- 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
index a7a75f4a..a86f8a3a 100644
--- 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