kunaljubce commented on PR #67896:
URL: https://github.com/apache/airflow/pull/67896#issuecomment-4628925658

   After the change, the failure is instant on UI and the logs:
   ```
   2026-06-05T06:34:40.251925969Z stdout F 2026-06-05T06:34:40.251769Z [error   
 ] Invalid executor_config for 
TaskInstanceKey(dag_id='test_k8s_executor_config_legacy_depr_configs', 
task_id='check_for_failure', run_id='manual__2026-06-05T06:34:39.956177+00:00', 
try_number=1, map_index=-1). Executor_config: {'KubernetesExecutor': 
{'config_file': '/some/path/kubeconfig.yaml'}} 
[airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor]
 loc=kubernetes_executor.py:221
   2026-06-05T06:34:40.252745511Z stdout F 2026-06-05T06:34:40.252642Z [info    
 ] Received executor event with state failed for task instance 
TaskInstanceKey(dag_id='test_k8s_executor_config_legacy_depr_configs', 
task_id='check_for_failure', run_id='manual__2026-06-05T06:34:39.956177+00:00', 
try_number=1, map_index=-1) 
[airflow.jobs.scheduler_job_runner.SchedulerJobRunner] 
loc=scheduler_job_runner.py:1262
   2026-06-05T06:34:40.260887552Z stdout F 2026-06-05T06:34:40.260697Z [info    
 ] TaskInstance Finished: dag_id=test_k8s_executor_config_legacy_depr_configs, 
task_id=check_for_failure, run_id=manual__2026-06-05T06:34:39.956177+00:00, 
map_index=-1, ti_id=019e967d-afdc-7505-a071-e6a1c1fe1b40, run_start_date=None, 
run_end_date=None, run_duration=None, state=queued, 
executor=KubernetesExecutor(parallelism=32), executor_state=failed, 
try_number=1, max_tries=0, pool=default_pool, queue=default, priority_weight=1, 
operator=PythonOperator, queued_dttm=2026-06-05 06:34:40.248354+00:00, 
scheduled_dttm=2026-06-05 06:34:40.237597+00:00,queued_by_job_id=4, pid=None 
[airflow.jobs.scheduler_job_runner.SchedulerJobRunner] 
loc=scheduler_job_runner.py:1354
   2026-06-05T06:34:40.261913261Z stdout F 2026-06-05T06:34:40.261694Z [error   
 ] Executor KubernetesExecutor(parallelism=32) reported that the task instance 
<TaskInstance: test_k8s_executor_config_legacy_depr_configs.check_for_failure 
manual__2026-06-05T06:34:39.956177+00:00 [queued] 
ti_id=019e967d-afdc-7505-a071-e6a1c1fe1b40> finished with state failed, but the 
task instance's state attribute is queued. Learn more: 
https://airflow.apache.org/docs/apache-airflow/stable/troubleshooting.html#task-state-changed-externally
 Extra info: Invalid executor_config passed [airflow.task] 
loc=taskinstance.py:1800
   2026-06-05T06:34:40.264229552Z stdout F 2026-06-05T06:34:40.264106Z [debug   
 ] Calling 'on_task_instance_failed' with {'previous_state': 
<TaskInstanceState.RUNNING: 'running'>, 'task_instance': <TaskInstance: 
test_k8s_executor_config_legacy_depr_configs.check_for_failure 
manual__2026-06-05T06:34:39.956177+00:00 [failed] 
ti_id=019e967d-afdc-7505-a071-e6a1c1fe1b40>, 'error': "Executor 
KubernetesExecutor(parallelism=32) reported that the task instance 
<TaskInstance: test_k8s_executor_config_legacy_depr_configs.check_for_failure 
manual__2026-06-05T06:34:39.956177+00:00 [queued] 
ti_id=019e967d-afdc-7505-a071-e6a1c1fe1b40> finished with state failed, but the 
task instance's state attribute is queued. Learn more: 
https://airflow.apache.org/docs/apache-airflow/stable/troubleshooting.html#task-state-changed-externally
 Extra info: Invalid executor_config passed"} 
[airflow._shared.listeners.listener] loc=listener.py:59
   2026-06-05T06:34:40.264410677Z stdout F 2026-06-05T06:34:40.264310Z [info    
 ] [InformaticaLineageListener] Task: check_for_failure State: failed 
[airflow.providers.informatica.plugins.listener] loc=listener.py:77
   2026-06-05T06:34:40.264469802Z stdout F 2026-06-05T06:34:40.264371Z [info    
 ] [InformaticaLineageListener] Skipping lineage handling for state: failed 
[airflow.providers.informatica.plugins.listener] loc=listener.py:80
   2026-06-05T06:34:40.264487261Z stdout F 2026-06-05T06:34:40.264415Z [debug   
 ] Result from 'on_task_instance_failed': [] 
[airflow._shared.listeners.listener] loc=listener.py:74
   2026-06-05T06:34:40.264546802Z stdout F 2026-06-05T06:34:40.264490Z [info    
 ] Marking task as FAILED. dag_id=test_k8s_executor_config_legacy_depr_configs, 
task_id=check_for_failure, run_id=manual__2026-06-05T06:34:39.956177+00:00, 
logical_date=20260605T063438, start_date=, end_date=20260605T063440 
[airflow.models.taskinstance] loc=taskinstance.py:1892
   ```
   
   <img width="1651" height="399" alt="image" 
src="https://github.com/user-attachments/assets/3d225c66-2392-4259-a22c-e5f9847b0cd0";
 />
   


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