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>
(cherry picked from commit 6823527)
  • Loading branch information
mmaslankaprv authored and Michal Maslanka committed Jan 23, 2024
1 parent 6317283 commit f4ffa61
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 f4ffa61

Please sign in to comment.