The GitHub Actions job "Tests (AMD)" on airflow.git/fix/67296-kpo-trigger-mapped-ti-key has succeeded. Run started by GitHub user paultmathew (triggered by paultmathew).
Head commit for run: fae29332b15ff22d587be6811e92b689929fc46a / Paul Mathew <[email protected]> Fix KubernetesPodTrigger.get_task_state KeyError on mapped TIs (#67296) The execution API's /states endpoint encodes the response key as ``f"{task_id}_{map_index}"`` for mapped TIs but the trigger was looking the value up by plain ``task_id``. For any mapped deferrable KubernetesPodOperator task that lookup raised KeyError, which cleanup()'s broad ``except Exception`` swallowed and skipped ``hook.delete_pod()`` -- so Mark Failed in the UI left the pod running until ``active_deadline_seconds`` expired. Compose the lookup key with the ``_{map_index}`` suffix when the TI is mapped, matching how the API serialises the response. cleanup() now sees the real state, ``safe_to_cancel()`` returns the right value, and mark-failed actually deletes the pod within the grace period. Co-authored-by: Cursor <[email protected]> Report URL: https://github.com/apache/airflow/actions/runs/26250711971 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
