Fix kubernetes executor watcher kube_client_request_args shadowing (#…

…45528) * Fix watcher kube_client_request_args shadowing * Update providers/src/airflow/providers/cncf/kubernetes/executors/kubernetes_executor_utils.py Apply suggestion by review Co-authored-by: Ryan Hatter <[email protected]> --------- Co-authored-by: Ryan Hatter <[email protected]>
apache · Jan 13, 2025 · 3c63bb6 · 3c63bb6
1 parent 05fe5a4
commit 3c63bb6
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/providers/src/airflow/providers/cncf/kubernetes/executors/kubernetes_executor_utils.py b/providers/src/airflow/providers/cncf/kubernetes/executors/kubernetes_executor_utils.py
@@ -147,10 +147,10 @@ def _run(
         # For info about k8s timeout settings see
         # https://github.com/kubernetes-client/python/blob/v29.0.0/examples/watch/timeout-settings.md
         # and https://github.com/kubernetes-client/python/blob/v29.0.0/kubernetes/client/api_client.py#L336-L339
-        client_timeout = 30
-        server_conn_timeout = 3600
-        kwargs["_request_timeout"] = client_timeout
-        kwargs["timeout_seconds"] = server_conn_timeout
+        if "_request_timeout" not in kwargs:
+            kwargs["_request_timeout"] = 30
+        if "timeout_seconds" not in kwargs:
+            kwargs["timeout_seconds"] = 3600
 
         logical_date_key = get_logical_date_key()
         for event in self._pod_events(kube_client=kube_client, query_kwargs=kwargs):