From 0e24aa1a93bc0c02e2be44414075471475e4c601 Mon Sep 17 00:00:00 2001 From: Vedu Joshi Date: Thu, 26 Jan 2017 04:42:38 +0530 Subject: [PATCH] labels need not be defined in kube inputs Avoid hitting KeyError Change-Id: I941bbbe1f647c9fdc887ed50b8ab30eaa4f21725 Closes-Bug: 1659436 --- .../kube-manager/kube_manager/vnc/vnc_network_policy.py | 2 +- src/container/kube-manager/kube_manager/vnc/vnc_pod.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/container/kube-manager/kube_manager/vnc/vnc_network_policy.py b/src/container/kube-manager/kube_manager/vnc/vnc_network_policy.py index 63af02aba25..9bf23b269e6 100644 --- a/src/container/kube-manager/kube_manager/vnc/vnc_network_policy.py +++ b/src/container/kube-manager/kube_manager/vnc/vnc_network_policy.py @@ -256,7 +256,7 @@ def _add_dest_pod_2_policy(self, pod_id, policy_id): self._apply_sg_2_pod(sg, pod_id) def vnc_pod_add(self, event): - labels = event['object']['metadata']['labels'] + labels = event['object']['metadata'].get('labels', {}) pod_id = event['object']['metadata']['uid'] for label in labels.items(): diff --git a/src/container/kube-manager/kube_manager/vnc/vnc_pod.py b/src/container/kube-manager/kube_manager/vnc/vnc_pod.py index 3edcd84d950..ff05ec2e118 100644 --- a/src/container/kube-manager/kube_manager/vnc/vnc_pod.py +++ b/src/container/kube-manager/kube_manager/vnc/vnc_pod.py @@ -198,7 +198,7 @@ def process(self, event): pod_id = event['object']['metadata'].get('uid') pod_name = event['object']['metadata'].get('name') pod_namespace = event['object']['metadata'].get('namespace') - labels = event['object']['metadata']['labels'] + labels = event['object']['metadata'].get('labels', {}) if event['type'] == 'ADDED' or event['type'] == 'MODIFIED': pod_node = event['object']['spec'].get('nodeName')