diff --git a/src/ert/storage/local_ensemble.py b/src/ert/storage/local_ensemble.py
index 8f3e6850958..8743c68052c 100644
--- a/src/ert/storage/local_ensemble.py
+++ b/src/ert/storage/local_ensemble.py
@@ -594,7 +594,9 @@ def load_cross_correlations(self) -> xr.Dataset:
 
     @require_write
     def save_observation_scaling_factors(self, dataset: polars.DataFrame) -> None:
-        dataset.write_parquet(self.mount_point / "observation_scaling_factors.parquet")
+        self._storage._to_parquet_transaction(
+            self.mount_point / "observation_scaling_factors.parquet", dataset
+        )
 
     def load_observation_scaling_factors(
         self,