Skip to content

Commit

Permalink
Merge pull request #24420 from WillemKauf/max_translated_offset_fix
Browse files Browse the repository at this point in the history
`rptest`: deflake `max_translated_offset()`
  • Loading branch information
bharathv authored Dec 5, 2024
2 parents cbecb9f + 0e20ff3 commit 9e06676
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion tests/rptest/tests/datalake/datalake_services.py
Original file line number Diff line number Diff line change
Expand Up @@ -160,7 +160,7 @@ def translation_done():
self.redpanda.logger.debug(
f"Current translated offsets: {offsets}")
return all([
offset and offset <= max_offset
max_offset and offset <= max_offset
for _, max_offset in offsets.items()
])

Expand Down

0 comments on commit 9e06676

Please sign in to comment.