diff --git a/tests/rptest/tests/nodes_decommissioning_test.py b/tests/rptest/tests/nodes_decommissioning_test.py index fb7a24d37e58..2516d02fcffd 100644 --- a/tests/rptest/tests/nodes_decommissioning_test.py +++ b/tests/rptest/tests/nodes_decommissioning_test.py @@ -591,11 +591,13 @@ def test_decommissioning_finishes_after_manual_cancellation(self): to_decommission = random.choice(self.redpanda.nodes) node_id = self.redpanda.node_id(to_decommission) + # throttle recovery + self._set_recovery_rate(100) + survivor_node = self._not_decommissioned_node(node_id) self.logger.info(f"decommissioning node: {node_id}", ) admin.decommission_broker(id=node_id) - self._set_recovery_rate(100) # wait for some partitions to start moving wait_until(lambda: self._partitions_moving(node=survivor_node), timeout_sec=15,