From 598a0b76cb883c8c7dedff74256f15ec96617480 Mon Sep 17 00:00:00 2001 From: Robin Han Date: Mon, 18 Dec 2023 17:21:18 +0800 Subject: [PATCH] fix(e2e): await clean up task start Signed-off-by: Robin Han --- tests/kafkatest/tests/core/reassign_partitions_test.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/tests/kafkatest/tests/core/reassign_partitions_test.py b/tests/kafkatest/tests/core/reassign_partitions_test.py index 3d14512774..ddfbafe8ab 100644 --- a/tests/kafkatest/tests/core/reassign_partitions_test.py +++ b/tests/kafkatest/tests/core/reassign_partitions_test.py @@ -130,7 +130,8 @@ def move_start_offset(self): # partition until the log start offset matches the end offset. The # latter is more robust. # 6->12 seconds to bypass the initial delay of cleanup task - time.sleep(12) + # the broker clean up task initial delay is 30s + time.sleep(12 + 30) @cluster(num_nodes=8) @matrix(bounce_brokers=[True, False],