The GitHub Actions job "Tests" on airflow.git/fix/k8s-executor-validation-56271 
has failed.
Run started by GitHub user shivaam (triggered by shivaam).

Head commit for run:
bc20ae495fb2ec0df72feed12c61a5763f7467f6 / Shivam Rastogi 
<[email protected]>
Fix KubernetesExecutor broken by executor validation in worker pods

Worker pods spawned by KubernetesExecutor are configured with only
LocalExecutor (via pod_template_file). When these pods parse DAGs,
_validate_executor_fields() rejects tasks that specify executors
not in the pod's local config (e.g., executor='KubernetesExecutor'),
causing UnknownExecutorException and "Dag not found during start up".

The fix adds a validate_executors parameter to DagBag (default True)
and sets it to False in the task runner's parse() function. Worker
pods don't need to validate executor assignments — that's the
scheduler/dag-processor's responsibility.

closes: #56271

Co-Authored-By: Claude Opus 4.6 (1M context) <[email protected]>

Report URL: https://github.com/apache/airflow/actions/runs/23398921328

With regards,
GitHub Actions via GitBox


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to