[airflow] 01/02: BugFix: K8s Executor Multinamespace mode is evaluated to true by default (#10410)

[ka...@apache.org]

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

kaxilnaik pushed a commit to branch v1-10-stable
in repository https://gitbox.apache.org/repos/asf/airflow.git

commit ec32e0af5faa43257b91bff21558c80df7ae10cc
Author: Kaxil Naik <ka...@gmail.com>
AuthorDate: Wed Aug 19 23:26:56 2020 +0100

    BugFix: K8s Executor Multinamespace mode is evaluated to true by default (#10410)
    
    (cherry picked from commit 3d334fdd98b1dd0e49b981c9cca70570a1da124e)
---
 airflow/executors/kubernetes_executor.py | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/airflow/executors/kubernetes_executor.py b/airflow/executors/kubernetes_executor.py
index b6784a8..0ae8f16 100644
--- a/airflow/executors/kubernetes_executor.py
+++ b/airflow/executors/kubernetes_executor.py
@@ -163,7 +163,7 @@ class KubeConfig:
         # cluster has RBAC enabled, your scheduler may need service account permissions to
         # create, watch, get, and delete pods in this namespace.
         self.kube_namespace = conf.get(self.kubernetes_section, 'namespace')
-        self.multi_namespace_mode = conf.get(self.kubernetes_section, 'multi_namespace_mode')
+        self.multi_namespace_mode = conf.getboolean(self.kubernetes_section, 'multi_namespace_mode')
         # The Kubernetes Namespace in which pods will be created by the executor. Note
         # that if your
         # cluster has RBAC enabled, your workers may need service account permissions to
@@ -265,14 +265,14 @@ class KubernetesJobWatcher(multiprocessing.Process, LoggingMixin):
 
     def __init__(self,
                  namespace,
-                 mult_namespace_mode,
+                 multi_namespace_mode,
                  watcher_queue,
                  resource_version,
                  worker_uuid,
                  kube_config):
         multiprocessing.Process.__init__(self)
         self.namespace = namespace
-        self.multi_namespace_mode = mult_namespace_mode
+        self.multi_namespace_mode = multi_namespace_mode
         self.worker_uuid = worker_uuid
         self.watcher_queue = watcher_queue
         self.resource_version = resource_version
@@ -403,7 +403,7 @@ class AirflowKubernetesScheduler(LoggingMixin):
         resource_version = KubeResourceVersion.get_current_resource_version()
         watcher = KubernetesJobWatcher(watcher_queue=self.watcher_queue,
                                        namespace=self.kube_config.kube_namespace,
-                                       mult_namespace_mode=self.kube_config.multi_namespace_mode,
+                                       multi_namespace_mode=self.kube_config.multi_namespace_mode,
                                        resource_version=resource_version,
                                        worker_uuid=self.worker_uuid,
                                        kube_config=self.kube_config)