diff --git a/airflow/providers/cncf/kubernetes/operators/pod.py b/airflow/providers/cncf/kubernetes/operators/pod.py index 3dc4df0903717..6b483cd4be93c 100644 --- a/airflow/providers/cncf/kubernetes/operators/pod.py +++ b/airflow/providers/cncf/kubernetes/operators/pod.py @@ -195,7 +195,7 @@ class KubernetesPodOperator(BaseOperator): Deprecated - use `on_finish_action` instead. :param termination_message_policy: The termination message policy of the base container. Default value is "File" - :param active_deadline_seconds: The active_deadline_seconds which matches to active_deadline_seconds + :param active_deadline_seconds: The active_deadline_seconds which translates to active_deadline_seconds in V1PodSpec. :param progress_callback: Callback function for receiving k8s container logs. """ diff --git a/kubernetes_tests/test_kubernetes_pod_operator.py b/kubernetes_tests/test_kubernetes_pod_operator.py index 7ee5ed7c5e1c3..13ae3835aad51 100644 --- a/kubernetes_tests/test_kubernetes_pod_operator.py +++ b/kubernetes_tests/test_kubernetes_pod_operator.py @@ -1348,12 +1348,13 @@ def __getattr__(self, name): class TestKubernetesPodOperator(BaseK8STest): @pytest.mark.parametrize("active_deadline_seconds", [10, 20]) def test_kubernetes_pod_operator_active_deadline_seconds(self, active_deadline_seconds): + ns = "default" k = KubernetesPodOperator( task_id=f"test_task_{active_deadline_seconds}", active_deadline_seconds=active_deadline_seconds, image="busybox", cmds=["sh", "-c", "echo 'hello world' && sleep 60"], - namespace="default", + namespace=ns, on_finish_action="keep_pod", ) @@ -1362,11 +1363,11 @@ def test_kubernetes_pod_operator_active_deadline_seconds(self, active_deadline_s with pytest.raises(AirflowException): k.execute(context) - pod = k.find_pod("default", context, exclude_checked=False) + pod = k.find_pod(ns, context, exclude_checked=False) k8s_client = client.CoreV1Api() - pod_status = k8s_client.read_namespaced_pod_status(name=pod.metadata.name, namespace="default") + pod_status = k8s_client.read_namespaced_pod_status(name=pod.metadata.name, namespace=ns) phase = pod_status.status.phase reason = pod_status.status.reason