Lee-W opened a new pull request, #71825: URL: https://github.com/apache/airflow/pull/71825
## Why Two tests for the newly added `IcebergTableSnapshotTrigger` (#71387) collect 2 events via `_collect(trigger, 2)`, whose default 1s wall-clock budget is too tight given the real `asyncio.to_thread` scheduling each polling round performs (head-snapshot lookup, plus asset-state-store get/set). Under CI's constrained/parallel runners, thread-pool scheduling latency occasionally pushes the total past 1s, so the collector times out before both events arrive and the assertion fails on an incomplete payload list. Observed failing on unrelated PRs: - https://github.com/apache/airflow/actions/runs/32140762877/job/95763173856 (`test_persists_the_watermark_on_each_event`) - https://github.com/apache/airflow/actions/runs/32140762877/job/95763173984 (`test_emits_once_per_new_snapshot`) ## What Widens the collection timeout to 3s for just these two tests. The trigger implementation itself is correct — a single sequential loop with no concurrency, so the emitted order is deterministic; this is purely a test budget issue. --- ##### Was generative AI tooling used to co-author this PR? - [X] Yes — Claude Code (Sonnet 5) Generated-by: Claude Code (Sonnet 5) following [the guidelines](https://github.com/apache/airflow/blob/main/contributing-docs/05_pull_requests.rst#gen-ai-assisted-contributions) -- 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]
