From d2b7ed0787bb3fd0d772f70d1c8a693b3018b861 Mon Sep 17 00:00:00 2001 From: Roger Johansson Date: Wed, 6 Aug 2025 16:05:07 +0200 Subject: [PATCH] Use configurable activation timeout --- src/Proto.Cluster/Partition/PartitionPlacementActor.cs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/Proto.Cluster/Partition/PartitionPlacementActor.cs b/src/Proto.Cluster/Partition/PartitionPlacementActor.cs index e877184b95..18f6be264d 100644 --- a/src/Proto.Cluster/Partition/PartitionPlacementActor.cs +++ b/src/Proto.Cluster/Partition/PartitionPlacementActor.cs @@ -74,9 +74,9 @@ private Task OnClusterTopology(IContext context, ClusterTopology msg) var cancellationToken = msg.TopologyValidityToken!.Value; - // TODO: Configurable timeout - var activationsCompleted = - _cluster.Gossip.WaitUntilInFlightActivationsAreCompleted(TimeSpan.FromSeconds(10), cancellationToken); + // Wait for all in-flight activations using the configured timeout + var activationsCompleted = _cluster.Gossip + .WaitUntilInFlightActivationsAreCompleted(_config.RebalanceActivationsCompletionTimeout, cancellationToken); // Waits until all members agree on a cluster topology and have no more in-flight activation requests context.ReenterAfter(activationsCompleted, async _ =>