You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by di...@apache.org on 2020/08/09 17:19:17 UTC
[airflow] branch v1-10-test updated: Fix init containers
This is an automated email from the ASF dual-hosted git repository.
dimberman pushed a commit to branch v1-10-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v1-10-test by this push:
new 9e2557a Fix init containers
9e2557a is described below
commit 9e2557a579ab9287293969662aa35e39b4b8b292
Author: Daniel Imberman <da...@gmail.com>
AuthorDate: Sun Aug 9 10:18:18 2020 -0700
Fix init containers
---
airflow/kubernetes/pod_launcher.py | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
diff --git a/airflow/kubernetes/pod_launcher.py b/airflow/kubernetes/pod_launcher.py
index 30cb26a..620df31 100644
--- a/airflow/kubernetes/pod_launcher.py
+++ b/airflow/kubernetes/pod_launcher.py
@@ -299,9 +299,8 @@ def _convert_to_airflow_pod(pod):
volumes, vol_secrets = _extract_volumes_and_secrets(pod.spec.volumes, base_container.volume_mounts)
secrets.extend(vol_secrets)
api_client = ApiClient()
- if pod.spec.init_containers is None:
- init_containers = [],
- else:
+ init_containers = pod.spec.init_containers
+ if pod.spec.init_containers is not None:
init_containers = [api_client.sanitize_for_serialization(i) for i in pod.spec.init_containers]
dummy_pod = Pod(
image=base_container.image,