Skip to content

Commit 5b43184

Browse files
authored
Use configurable activation timeout (#2247)
1 parent ac5dde9 commit 5b43184

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/Proto.Cluster/Partition/PartitionPlacementActor.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -74,9 +74,9 @@ private Task OnClusterTopology(IContext context, ClusterTopology msg)
7474

7575
var cancellationToken = msg.TopologyValidityToken!.Value;
7676

77-
// TODO: Configurable timeout
78-
var activationsCompleted =
79-
_cluster.Gossip.WaitUntilInFlightActivationsAreCompleted(TimeSpan.FromSeconds(10), cancellationToken);
77+
// Wait for all in-flight activations using the configured timeout
78+
var activationsCompleted = _cluster.Gossip
79+
.WaitUntilInFlightActivationsAreCompleted(_config.RebalanceActivationsCompletionTimeout, cancellationToken);
8080

8181
// Waits until all members agree on a cluster topology and have no more in-flight activation requests
8282
context.ReenterAfter(activationsCompleted, async _ =>

0 commit comments

Comments
 (0)