rptest: Fix race condition in CloudRetentionTest #16361
Merged
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Fixes #15893
The test has race condition. It starts consumer before all data is produced and before retention kicks in. The original intention was to let the consumer validate the data after retention. Basically, to check that the data is readable. But because of that the consumer were reading data that was removed by retention. It was racing with the producer. Largely simplifed version of what was happening there.
This PR fixes this by starting the consumer after retention is confirmed.
Backports Required
Release Notes