diff --git a/tests/rptest/tests/retention_policy_test.py b/tests/rptest/tests/retention_policy_test.py index 1d896b837fb1..59463ac9fe27 100644 --- a/tests/rptest/tests/retention_policy_test.py +++ b/tests/rptest/tests/retention_policy_test.py @@ -473,7 +473,7 @@ def cloud_log_segment_count() -> int: f"Waiting for {local_seg_count - 1} segments to be uploaded to the cloud" ) # Wait for everything to be uploaded to the cloud. - wait_until(lambda: cloud_log_segment_count() == local_seg_count - 1, + wait_until(lambda: cloud_log_segment_count() >= local_seg_count - 1, timeout_sec=10, backoff_sec=2, err_msg=f"Segments not uploaded")