The GitHub Actions job "Tests (AMD)" on airflow.git/fix-dag-processor-pending-rollback-on-integrity-error has succeeded. Run started by GitHub user steveahnahn (triggered by steveahnahn).
Head commit for run: 7f443924c6260c3a4acad231d72b46ef33494d8b / Steve Ahn <[email protected]> Fix Dag processor crash with PendingRollbackError on concurrent dag_tag inserts With multiple Dag processors (HA), concurrent parsing of the same dag races on the dag_tag insert and one processor gets an IntegrityError. run_with_db_retries retries every DBAPIError, but the parsing-results retry loop only rolled the session back for OperationalError, so the retry ran on a poisoned session and crashed with PendingRollbackError, masking the original error and failing the whole parse batch instead of recovering on the second attempt. Align both except clauses with the run_with_db_retries policy (DBAPIError, StaleDataError): roll back before the retry, and let retryable DB errors from per-dag serialization reach the retry loop instead of being misrecorded as dag import errors. Report URL: https://github.com/apache/airflow/actions/runs/29166529787 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
