The GitHub Actions job "Tests (AMD)" on airflow.git/fix-71070-asset-partition-dedup has failed. Run started by GitHub user anmolxlight (triggered by anmolxlight).
Head commit for run: 09fcebfadc3db72de21659392db76ef445fc5d09 / anmolxlight <[email protected]> Document and test that APDR savepoint rollback cannot expunge pending log rows A SAVEPOINT rollback on a lost APDR insert race expunges every ORM object in the session's pending state, which could look like a risk for the unflushed Log/PartitionedAssetKeyLog rows _queue_partitioned_dags accumulates across loop iterations before the SAVEPOINT opens. Session.begin_nested() itself flushes that pending state into the parent transaction before opening the SAVEPOINT, so those rows are already persistent and not among what a rollback can touch. Document this in _get_or_create_apdr and pin it with a regression test that forces a lost race and asserts an unflushed log row added earlier survives. Signed-off-by: anmolxlight <[email protected]> Report URL: https://github.com/apache/airflow/actions/runs/31166079547 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
