add fsync to atomic_save for correctness

mahmoud · Feb 3, 2025 · a7d9afd · a7d9afd
1 parent 6e0354e
commit a7d9afd
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/boltons/fileutils.py b/boltons/fileutils.py
@@ -465,6 +465,9 @@ def __enter__(self):
 
     def __exit__(self, exc_type, exc_val, exc_tb):
         if self.part_file:
+            # Ensure data is flushed and synced to disk before closing
+            self.part_file.flush()
+            os.fsync(self.part_file.fileno())
             self.part_file.close()
         if exc_type:
             if self.rm_part_on_exc: