Repository: incubator-airflow Updated Branches: refs/heads/master d642e38ec -> c5a5ae947
[AIRFLOW-2533] Fix path to DAG's on kubernetes executor workers Closes #3470 from bnutt/brian/kubernetes_executor_fix_path_to_dags Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/c5a5ae94 Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/c5a5ae94 Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/c5a5ae94 Branch: refs/heads/master Commit: c5a5ae947d966424a4e38c448f98c36a982125c9 Parents: d642e38 Author: Brian Nutt <[email protected]> Authored: Sat Jun 9 22:13:13 2018 +0200 Committer: Fokko Driesprong <[email protected]> Committed: Sat Jun 9 22:13:13 2018 +0200 ---------------------------------------------------------------------- airflow/contrib/kubernetes/worker_configuration.py | 3 --- 1 file changed, 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/c5a5ae94/airflow/contrib/kubernetes/worker_configuration.py ---------------------------------------------------------------------- diff --git a/airflow/contrib/kubernetes/worker_configuration.py b/airflow/contrib/kubernetes/worker_configuration.py index ea0aa23..f333f80 100644 --- a/airflow/contrib/kubernetes/worker_configuration.py +++ b/airflow/contrib/kubernetes/worker_configuration.py @@ -178,9 +178,6 @@ class WorkerConfiguration(LoggingMixin): annotations = { 'iam.cloud.google.com/service-account': gcp_sa_key } if gcp_sa_key else {} - airflow_path = airflow_command.split('-sd')[-1] - airflow_path = self.worker_airflow_home + airflow_path.split('/')[-1] - airflow_command = airflow_command.split('-sd')[0] + '-sd ' + airflow_path return Pod( namespace=namespace,
