Introducing class constant to make worker pod log lines configurable (#33378)

Author: amoghrajesh

airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py

@@ -147,6 +147,7 @@ class PodReconciliationError(AirflowException):
 class KubernetesExecutor(BaseExecutor):
     """Executor for Kubernetes."""
 
+    RUNNING_POD_LOG_LINES = 100
     supports_ad_hoc_ti_run: bool = True
 
     def __init__(self):
@@ -502,7 +503,7 @@ def get_task_log(self, ti: TaskInstance, try_number: int) -> tuple[list[str], li
                 namespace=namespace,
                 container="base",
                 follow=False,
-                tail_lines=100,
+                tail_lines=self.RUNNING_POD_LOG_LINES,
                 _preload_content=False,
             )
             for line in res:

tests/providers/cncf/kubernetes/executors/test_kubernetes_executor.py

@@ -228,6 +228,19 @@ def test_delete_pod_404_not_raised(self, mock_watcher, mock_client, mock_kube_cl
         finally:
             kube_executor.end()
 
+    def test_running_pod_log_lines(self):
+        # default behaviour
+        kube_executor = KubernetesExecutor()
+        assert kube_executor.RUNNING_POD_LOG_LINES == 100
+
+        # monkey-patching for second executor
+        kube_executor_2 = KubernetesExecutor()
+        kube_executor_2.RUNNING_POD_LOG_LINES = 200
+
+        # monkey-patching should not affect the class constant
+        assert kube_executor.RUNNING_POD_LOG_LINES == 100
+        assert kube_executor_2.RUNNING_POD_LOG_LINES == 200
+
 
 class TestKubernetesExecutor:
     """