Skip to content

Commit 377e60c

Browse files
committed
rptest: remove wait() in nodes_decommissioning_test
The second `producer.wait()` call in `verify()` will fail with the new assert if this `wait()` is left here. It is also unnecessary for the test as written.
1 parent eb3daa3 commit 377e60c

File tree

1 file changed

+0
-1
lines changed

1 file changed

+0
-1
lines changed

tests/rptest/tests/nodes_decommissioning_test.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -490,7 +490,6 @@ def calculate_total_learners_gap() -> int | None:
490490

491491
self.logger.info(f"decommissioning node: {to_decommission_id}", )
492492
self._decommission(to_decommission_id)
493-
self.producer.wait()
494493

495494
def learner_gap_reported(decommissioned_node_id: int):
496495
total_gap = calculate_total_learners_gap()

0 commit comments

Comments
 (0)