Use _to_parquet_transaction for saving scaling factors

equinor · Sep 27, 2024 · 5aac172 · 5aac172
1 parent d890118
commit 5aac172
Showing 1 changed file with 3 additions and 1 deletion.
diff --git 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,