From ffcbd7ba95d4905153eb37dde35238ee59bf4fdd Mon Sep 17 00:00:00 2001 From: "Paul.Bramhall" Date: Wed, 23 Jan 2019 15:45:36 +0000 Subject: [PATCH] Ensure that we pass the command to the Kubernetes Pod as a List --- airflow/contrib/kubernetes/worker_configuration.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/contrib/kubernetes/worker_configuration.py b/airflow/contrib/kubernetes/worker_configuration.py index 62c6ef68b03b3..489ecc1a951f2 100644 --- a/airflow/contrib/kubernetes/worker_configuration.py +++ b/airflow/contrib/kubernetes/worker_configuration.py @@ -238,7 +238,7 @@ def make_pod(self, namespace, worker_uuid, pod_id, dag_id, task_id, execution_da image=kube_executor_config.image or self.kube_config.kube_image, image_pull_policy=(kube_executor_config.image_pull_policy or self.kube_config.kube_image_pull_policy), - cmds=airflow_command, + cmds=airflow_command.split(" "), labels={ 'airflow-worker': worker_uuid, 'dag_id': dag_id,