This is an automated email from the ASF dual-hosted git repository.
rom pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new f8f604a43d4 Fix kpo log_events_on_failure logs warnings at warning
level (#54967)
f8f604a43d4 is described below
commit f8f604a43d4d03ec41915369774e40aedf0acfa0
Author: Keto D. Zhang <[email protected]>
AuthorDate: Sat Sep 6 23:56:47 2025 -0700
Fix kpo log_events_on_failure logs warnings at warning level (#54967)
---
.../src/airflow/providers/cncf/kubernetes/operators/pod.py | 7 ++++---
.../kubernetes/tests/unit/cncf/kubernetes/operators/test_pod.py | 4 ++--
2 files changed, 6 insertions(+), 5 deletions(-)
diff --git
a/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/operators/pod.py
b/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/operators/pod.py
index 76d3b4eb3ff..00995d7bedc 100644
---
a/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/operators/pod.py
+++
b/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/operators/pod.py
@@ -1088,10 +1088,11 @@ class KubernetesPodOperator(BaseOperator):
"""Will fetch and emit events from pod."""
with _optionally_suppress(reraise=reraise):
for event in self.pod_manager.read_pod_events(pod).items:
- if event.type == PodEventType.NORMAL.value:
- self.log.info("Pod Event: %s - %s", event.reason,
event.message)
+ if event.type == PodEventType.WARNING.value:
+ self.log.warning("Pod Event: %s - %s", event.reason,
event.message)
else:
- self.log.error("Pod Event: %s - %s", event.reason,
event.message)
+ # events.k8s.io/v1 at this stage will always be Normal
+ self.log.info("Pod Event: %s - %s", event.reason,
event.message)
def _read_pod_container_states(self, pod, *, reraise=True) -> None:
"""Log detailed container states of pod for debugging."""
diff --git
a/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/operators/test_pod.py
b/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/operators/test_pod.py
index e1369aefa0c..ad68c5f410d 100644
--- a/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/operators/test_pod.py
+++ b/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/operators/test_pod.py
@@ -2799,8 +2799,8 @@ def test_read_pod_events(mock_log, mock_pod_manager):
mock_event_normal.reason,
mock_event_normal.message,
)
- # Assert that event with type `Warning` is logged as error.
- mock_log.error.assert_called_once_with(
+ # Assert that event with type `Warning` is logged as warning.
+ mock_log.warning.assert_called_once_with(
"Pod Event: %s - %s",
mock_event_error.reason,
mock_event_error.message,
