1fanwang commented on issue #71847: URL: https://github.com/apache/airflow/issues/71847#issuecomment-5361335490
Tested `apache-airflow-providers-apache-iceberg==2.1.0rc1` from PyPI for https://github.com/apache/airflow/pull/71387 on Airflow 3.3.1 and Python 3.12. A real `airflow standalone` stack watched `default.orders` in a persistent PyIceberg SQL catalog. The first snapshot created one successful asset-triggered Dag run. Restarting the stack did not create a duplicate. A second snapshot created one more successful run, and the stored watermark moved to the new snapshot. <details><summary>Raw evidence</summary> ```console airflow=3.3.1 provider=2.1.0rc1 trigger_file=/usr/python/lib/python3.12/site-packages/airflow/providers/apache/iceberg/triggers/iceberg.py init_snapshot_id=7521888404468231469 standalone_run_1=ready dag_runs=[('asset_triggered__2026-08-20T20:28:40.550574+00:00_FIP5pzbK', 'asset_triggered', 'success')] watchers=[('airflow.providers.apache.iceberg.triggers.iceberg.IcebergTableSnapshotTrigger', 'orders_commits', 'iceberg_orders')] watermarks=[('iceberg_orders', 'snapshot_id', '7521888404468231469', 'watcher')] standalone_run_2=ready dag_runs=[('asset_triggered__2026-08-20T20:28:40.550574+00:00_FIP5pzbK', 'asset_triggered', 'success')] watermarks=[('iceberg_orders', 'snapshot_id', '7521888404468231469', 'watcher')] append_snapshot_id=511192996627067273 dag_runs=[('asset_triggered__2026-08-20T20:28:40.550574+00:00_FIP5pzbK', 'asset_triggered', 'success'), ('asset_triggered__2026-08-20T20:30:14.639421+00:00_eqMjmKHK', 'asset_triggered', 'success')] watermarks=[('iceberg_orders', 'snapshot_id', '511192996627067273', 'watcher')] RC_E2E_RESULT=PASS ``` </details> Addressed. --- Drafted-by: GitHub Copilot CLI (GPT-5.6 Sol) (no human review before posting) -- 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]
