Merge pull request #3076 from efiop/rwlock_sync

rwlock: flush and fsync
iterative · Jan 11, 2020 · 3e97886 · 3e97886
2 parents b7f9e73 + c190643
commit 3e97886
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/dvc/rwlock.py b/dvc/rwlock.py
@@ -50,6 +50,9 @@ def _edit_rwlock(lock_dir):
     yield lock
     with open(path, "w+") as fobj:
         json.dump(lock, fobj)
+        # NOTE: flush and fsync to ensure that rwlock contents are saved
+        fobj.flush()
+        os.fsync(fobj.fileno())
 
 
 def _infos_to_str(infos):