venkatamandavilli-code commented on issue #68628: URL: https://github.com/apache/airflow/issues/68628#issuecomment-4724826184
Thanks for reporting this. This looks like a flaky timing-related failure rather than something specific to the linked PR, especially since the same test is also failing on main with a `TimeoutError`. Since the timeout occurs in `test_ack_mode_queue_full_during_fanout_does_not_break_iteration`, it may be worth checking whether the test is relying on timing assumptions that are too tight for CI environments. The `asyncio.wait_for(..., timeout=2.0)` timeout may not be sufficient under slower or loaded CI runners, especially if queue backpressure or fanout scheduling is involved. It may also be useful to confirm whether the collector coroutine can get blocked waiting for an item that is never yielded after the queue-full condition is triggered. This seems important to stabilize because it can block unrelated PRs when the full core test suite runs. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
