The GitHub Actions job "Tests (AMD)" on airflow.git/scheduler-enqueue-readability has failed. Run started by GitHub user ashb (triggered by ashb).
Head commit for run: 007fd8b27dc63e2602ae468848556dbe48ecf452 / Ash Berlin-Taylor <[email protected]> Extract _acquire_pool_capacity from _critical_section_enqueue_task_instances Split the monolithic `_executable_task_instances_to_queued` into two focused methods: - `_acquire_pool_capacity`: takes the advisory lock and reads pool utilisation via SELECT FOR UPDATE. Returns (pools, max_tis, starved_pools) so callers can short-circuit when all pools are full before doing any TI selection work. - `_select_task_instances_to_queue`: given pre-computed pool capacity, selects eligible SCHEDULED TIs and moves them to QUEUED. Accepts the pools dict and starved_pools set as parameters, making it directly testable without needing a real lock or DB pool read. `_critical_section_enqueue_task_instances` now calls these two methods in sequence, making the two-phase structure (acquire capacity, then select and queue) visible at the orchestration level. All test call sites updated to call `_select_task_instances_to_queue` directly with a `make_pool_stats()` helper, removing the dependency on pool row locking in unit tests. Report URL: https://github.com/apache/airflow/actions/runs/25811124904 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
