(airflow) branch main updated: Fix KuberetesPodTriggerer use correct parameter name to read pod logs. (#58489)

[jscheffl]

This is an automated email from the ASF dual-hosted git repository.

jscheffl 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 db02322941d Fix KuberetesPodTriggerer use correct parameter name to 
read pod logs. (#58489)
db02322941d is described below

commit db02322941d30d2fb9c6c4e5635e61de6eddd1ff
Author: AutomationDev85 <96178949+automationde...@users.noreply.github.com>
AuthorDate: Thu Nov 20 22:15:34 2025 +0100

    Fix KuberetesPodTriggerer use correct parameter name to read pod logs. 
(#58489)
    
    * Use correct parameter name in read_namespaced_pod_log call.
    
    * Fix unit test
    
    ---------
    
    Co-authored-by: AutomationDev85 <AutomationDev85>
---
 .../src/airflow/providers/cncf/kubernetes/hooks/kubernetes.py           | 2 +-
 .../cncf/kubernetes/tests/unit/cncf/kubernetes/hooks/test_kubernetes.py | 2 +-
 .../google/tests/unit/google/cloud/hooks/test_kubernetes_engine.py      | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/hooks/kubernetes.py
 
b/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/hooks/kubernetes.py
index c02488bee8b..0c06c3d29d9 100644
--- 
a/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/hooks/kubernetes.py
+++ 
b/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/hooks/kubernetes.py
@@ -939,7 +939,7 @@ class AsyncKubernetesHook(KubernetesHook):
                 logs = await v1_api.read_namespaced_pod_log(
                     name=name,
                     namespace=namespace,
-                    container_name=container_name,
+                    container=container_name,
                     follow=False,
                     timestamps=True,
                     since_seconds=since_seconds,
diff --git 
a/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/hooks/test_kubernetes.py 
b/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/hooks/test_kubernetes.py
index 86e6e8304be..616c73b5e82 100644
--- 
a/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/hooks/test_kubernetes.py
+++ 
b/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/hooks/test_kubernetes.py
@@ -1072,7 +1072,7 @@ class TestAsyncKubernetesHook:
         lib_method.assert_called_with(
             name=POD_NAME,
             namespace=NAMESPACE,
-            container_name=CONTAINER_NAME,
+            container=CONTAINER_NAME,
             follow=False,
             timestamps=True,
             since_seconds=10,
diff --git 
a/providers/google/tests/unit/google/cloud/hooks/test_kubernetes_engine.py 
b/providers/google/tests/unit/google/cloud/hooks/test_kubernetes_engine.py
index e5a31b2327f..bec4c15146f 100644
--- a/providers/google/tests/unit/google/cloud/hooks/test_kubernetes_engine.py
+++ b/providers/google/tests/unit/google/cloud/hooks/test_kubernetes_engine.py
@@ -539,7 +539,7 @@ class TestGKEKubernetesAsyncHook:
             namespace=POD_NAMESPACE,
             follow=False,
             timestamps=True,
-            container_name=None,
+            container=None,
             since_seconds=None,
         )
         assert "Test string #1" in logs