The GitHub Actions job "Tests (AMD)" on airflow.git/iceberg-snapshot-trigger has failed. Run started by GitHub user 1fanwang (triggered by 1fanwang).
Head commit for run: 244516f64e352ce37dd88cce3a5b754b42f61342 / 1fanwang <[email protected]> Drop shared_stream_key so the triggerer runs the poll loop A non-None shared_stream_key sends the triggerer to filter_shared_stream instead of run(), and the base method raises because this trigger implements neither it nor open_shared_stream. The trigger never polled; every test passed because they call run() directly. Sharing was not reachable anyway: the key omits the table, so one poll could only serve a group by listing the whole catalog. Each trigger polls its own table, which is what run() already did. Also narrow the watermark guard. A state store backend raises ValueError from the same call as the several-assets case, so catching both hid a real failure and disabled the watermark silently. Cover the triggerer's dispatch rather than calling run() directly, so a reintroduced key fails instead of passing. Signed-off-by: 1fanwang <[email protected]> Report URL: https://github.com/apache/airflow/actions/runs/31535853534 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
