Skip to content

Commit

Permalink
tests: wait for acks in upgrade test
Browse files Browse the repository at this point in the history
Wait for at least some of the messages to be successfully written to
topic before starting consumers to prevent them trying to read empty
partition.

Signed-off-by: Michal Maslanka <michal@redpanda.com>
  • Loading branch information
mmaslankaprv committed Jan 2, 2024
1 parent 3b2eac5 commit 6823527
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions tests/rptest/tests/upgrade_test.py
Original file line number Diff line number Diff line change
Expand Up @@ -226,6 +226,9 @@ def test_upgrade_with_all_workloads(self, single_upgrade):
# First version, start up the workload
self._producer.start(clean=False)
self._producer.wait_for_offset_map()
self._producer.wait_for_acks(100,
timeout_sec=10,
backoff_sec=2)
wrote_at_least = self._producer.produce_status.acked
for consumer in self._consumers:
consumer.start(clean=False)
Expand Down

0 comments on commit 6823527

Please sign in to comment.