kunaljubce commented on PR #67896: URL: https://github.com/apache/airflow/pull/67896#issuecomment-4629352178
Also validated with correct configs and the dag is succeeding as expected: [test_k8s_executor_config_legacy_correct_configs.py](https://github.com/user-attachments/files/28629446/test_k8s_executor_config_legacy_correct_configs.py) ``` → cat /var/folders/4y/hpq5jk211d38sg8p7ry2ndd80000gp/T/kind_logs_airflow-python-3.10-v1.30.13/airflow-python-3.10-v1.30.13-worker/containers/airflow-scheduler-794ddcc7b4-pjdzs_airflow_scheduler-58768f7c960f35ef881f2bcca95a2652cfec4ae29cedd64952ec7c60bec857f2.log | grep -i "success\|succeeded" 2026-06-05T07:46:23.535930961Z stdout F 2026-06-05T07:46:23.535867Z [info ] Marking run <DagRun test_k8s_executor_config_legacy_correct_configs @ 2026-06-05 07:46:04+00:00: manual__2026-06-05T07:46:06.020918+00:00, state:running, queued_at: 2026-06-05 07:46:06.031141+00:00. run_type: manual> successful [airflow.models.dagrun.DagRun] loc=dagrun.py:1205 2026-06-05T07:46:23.536007127Z stdout F 2026-06-05T07:46:23.535951Z [debug ] Calling 'on_dag_run_success' with {'dag_run': <DagRun test_k8s_executor_config_legacy_correct_configs @ 2026-06-05 07:46:04+00:00: manual__2026-06-05T07:46:06.020918+00:00, state:success, queued_at: 2026-06-05 07:46:06.031141+00:00. run_type: manual>, 'msg': 'success'} [airflow._shared.listeners.listener] loc=listener.py:59 2026-06-05T07:46:23.536059627Z stdout F 2026-06-05T07:46:23.536021Z [debug ] Result from 'on_dag_run_success': [] [airflow._shared.listeners.listener] loc=listener.py:74 2026-06-05T07:46:23.536108836Z stdout F 2026-06-05T07:46:23.536062Z [info ] DagRun Finished: dag_id=test_k8s_executor_config_legacy_correct_configs, logical_date=2026-06-05 07:46:04+00:00, run_id=manual__2026-06-05T07:46:06.020918+00:00, run_start_date=2026-06-05 07:46:06.539397+00:00, run_end_date=2026-06-05 07:46:23.535908+00:00, run_duration=16.996511, state=success, run_type=manual, data_interval_start=2026-06-05 07:46:04+00:00, data_interval_end=2026-06-05 07:46:04+00:00, [airflow.models.dagrun.DagRun] loc=dagrun.py:1271 2026-06-05T07:46:25.180544628Z stdout F 2026-06-05T07:46:25.180427Z [info ] Event: test-k8s-executor-config-legacy-correct-configs-check-x3vrkcwa Succeeded, annotations: <omitted> [airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.KubernetesJobWatcher] loc=kubernetes_executor_utils.py:322 2026-06-05T07:46:25.60857942Z stdout F 2026-06-05T07:46:25.608149Z [debug ] response body: {"kind":"Pod","apiVersion":"v1","metadata":{"name":"test-k8s-executor-config-legacy-correct-configs-check-x3vrkcwa","namespace":"airflow","uid":"111c1643-b231-4b7e-a4e2- ... 2026-06-05T07:46:25.613855003Z stdout F 2026-06-05T07:46:25.613794Z [info ] Event: test-k8s-executor-config-legacy-correct-configs-check-x3vrkcwa Succeeded, annotations: <omitted> [airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.KubernetesJobWatcher] loc=kubernetes_executor_utils.py:322 2026-06-05T07:46:25.616947003Z stdout F 2026-06-05T07:46:25.616844Z [info ] Received executor event with state success for task instance TaskInstanceKey(dag_id='test_k8s_executor_config_legacy_correct_configs', task_id='check_for_failure', run_id='manual__2026-06-05T07:46:06.020918+00:00', try_number=1, map_index=-1) [airflow.jobs.scheduler_job_runner.SchedulerJobRunner] loc=scheduler_job_runner.py:1262 2026-06-05T07:46:25.619410753Z stdout F 2026-06-05T07:46:25.619321Z [info ] Event: test-k8s-executor-config-legacy-correct-configs-check-x3vrkcwa Succeeded, annotations: <omitted> [airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.KubernetesJobWatcher] loc=kubernetes_executor_utils.py:322 2026-06-05T07:46:25.621444753Z stdout F 2026-06-05T07:46:25.621337Z [info ] TaskInstance Finished: dag_id=test_k8s_executor_config_legacy_correct_configs, task_id=check_for_failure, run_id=manual__2026-06-05T07:46:06.020918+00:00, map_index=-1, ti_id=019e96bf-165c-73f2-a28c-849a0866dc9f, run_start_date=2026-06-05 07:46:14.614240+00:00, run_end_date=2026-06-05 07:46:23.205383+00:00, run_duration=8.591143, state=success, executor=KubernetesExecutor(parallelism=32), executor_state=success, try_number=1, max_tries=0, pool=default_pool, queue=default, priority_weight=1, operator=PythonOperator, queued_dttm=2026-06-05 07:46:06.613745+00:00, scheduled_dttm=2026-06-05 07:46:06.573257+00:00,queued_by_job_id=3, pid=15 [airflow.jobs.scheduler_job_runner.SchedulerJobRunner] loc=scheduler_job_runner.py:1354 ``` <img width="1651" height="399" alt="image" src="https://github.com/user-attachments/assets/2201c610-ac8d-451b-b9f0-5d3b32480d8e"; /> -- 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]
