krish01omni opened a new pull request, #74864:
URL: https://github.com/apache/airflow/pull/74864

   ## Description
   Fix DynamicRegion.get_or_create_many() to properly handle scheduler-created 
DagRuns for dynamically mapped tasks.
   Current implementation breaks HA locks when creating regions.
   
   fixes #74860
   
   ## Proposed Changes
   - Added HA lock protection in DynamicRegion.get_or_create_many()
   - Prevented unexpected commits that break HA locks
   - Ensured compatibility with scheduler-created DagRuns
   
   ## Test Coverage
   - Test DynamicRegion.get_or_create_many() with scheduler-created DagRuns
   - Test HA lock integrity during region creation
   
   ## Checklist
   - [x] Follows Airflow conventions
   - [x] HA lock safe
   - [x] Includes test coverage
   


-- 
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]

Reply via email to