diff --git a/crates/ecstore/src/services/rebalance/control.rs b/crates/ecstore/src/services/rebalance/control.rs index 97cc6fc34..98d66a5b2 100644 --- a/crates/ecstore/src/services/rebalance/control.rs +++ b/crates/ecstore/src/services/rebalance/control.rs @@ -41,7 +41,7 @@ fn ensure_rebalance_activation_pool_meta_allowed(meta: &PoolMeta) -> Result<()> } pub(super) enum RebalanceWorkerActivationFence { - Ready(PoolRebalanceActivationFence), + Ready(Box), NotStartedTerminal, } @@ -324,7 +324,7 @@ impl ECStore { return Ok(RebalanceWorkerActivationFence::NotStartedTerminal); } - Ok(RebalanceWorkerActivationFence::Ready(activation_fence)) + Ok(RebalanceWorkerActivationFence::Ready(Box::new(activation_fence))) } #[tracing::instrument(skip_all)] diff --git a/crates/ecstore/src/services/rebalance/rebalance_unit_tests.rs b/crates/ecstore/src/services/rebalance/rebalance_unit_tests.rs index c82eda451..c4a67d9e8 100644 --- a/crates/ecstore/src/services/rebalance/rebalance_unit_tests.rs +++ b/crates/ecstore/src/services/rebalance/rebalance_unit_tests.rs @@ -2752,8 +2752,10 @@ async fn test_old_worker_cannot_mutate_replacement_rebalance_state() { ..Default::default() }; let store = test_store_with_rebalance_meta(meta); - let mut fi = FileInfo::default(); - fi.size = 128; + let fi = FileInfo { + size: 128, + ..Default::default() + }; for err in [ store