yakovlef opened a new pull request, #76827: URL: https://github.com/apache/airflow/pull/76827
closes: #76738 when two TIs report success at the same time and emit the same new asset through an alias, the loser got an IntegrityError and was marked FAILED without retry - dynamic AssetModel creation in register_asset_changes_in_db now inserts in a savepoint, on IntegrityError it reuses the row the other writer created - _add_asset_alias_association links aliases in a savepoint, on conflict reloads asset_model.aliases and adds only the missing ones (same pattern as _get_or_create_apdr) - 2 tests that reproduce both cases from the issue deterministically (second session commits between our read and our insert), both failed on postgres before the fix the catch-all in ti_update_state that turns any error into a non-retryable FAILED is left as is, can do that separately if wanted --- ##### Was generative AI tooling used to co-author this PR? - [X] Yes (please specify the tool below) -- 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]
