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 <[email protected]> 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)
