Skip to content

Commit db02322

Browse files
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>
1 parent 0aa2ea7 commit db02322

3 files changed

Lines changed: 3 additions & 3 deletions

File tree

providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/hooks/kubernetes.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -939,7 +939,7 @@ async def read_logs(
939939
logs = await v1_api.read_namespaced_pod_log(
940940
name=name,
941941
namespace=namespace,
942-
container_name=container_name,
942+
container=container_name,
943943
follow=False,
944944
timestamps=True,
945945
since_seconds=since_seconds,

providers/cncf/kubernetes/tests/unit/cncf/kubernetes/hooks/test_kubernetes.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1072,7 +1072,7 @@ async def test_read_logs(self, lib_method, kube_config_loader):
10721072
lib_method.assert_called_with(
10731073
name=POD_NAME,
10741074
namespace=NAMESPACE,
1075-
container_name=CONTAINER_NAME,
1075+
container=CONTAINER_NAME,
10761076
follow=False,
10771077
timestamps=True,
10781078
since_seconds=10,

providers/google/tests/unit/google/cloud/hooks/test_kubernetes_engine.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -539,7 +539,7 @@ async def test_read_logs(self, read_namespaced_pod_log, get_conn_mock, async_hoo
539539
namespace=POD_NAMESPACE,
540540
follow=False,
541541
timestamps=True,
542-
container_name=None,
542+
container=None,
543543
since_seconds=None,
544544
)
545545
assert "Test string #1" in logs

0 commit comments

Comments
 (0)