https://github.com/feldera/cloud/actions/runs/31560300557/job/94005605713 failed with:
> assert transmitted_records() == expected_transmitted_records
E assert 3 == 6
E + where 3 = <function test_concurrent_bootstrap_enterprise.<locals>.transmitted_records at 0x78704ef68790>()
The calling code is this:
# At cutover the modified view re-emits its full contents (all backfilled
# rows), unlike silent bootstrap which suppresses them.
expected_transmitted_records += backfilled_records
wait_for_output_progress(
min_processed_records=expected_processed_records,
expected_transmitted_records=expected_transmitted_records,
)
It looks to me that the test expects that as soon as processed_records catches up to the expectation, the transmitted records must catch up to its own expectation at the exact same instant. It appears not to do that. I am not confident that that is a reasonable expectation, though. @ryzhyk should this be relaxed to give some time for the transmitted records to catch up?
https://github.com/feldera/cloud/actions/runs/31560300557/job/94005605713 failed with:
The calling code is this:
It looks to me that the test expects that as soon as processed_records catches up to the expectation, the transmitted records must catch up to its own expectation at the exact same instant. It appears not to do that. I am not confident that that is a reasonable expectation, though. @ryzhyk should this be relaxed to give some time for the transmitted records to catch up?