labels need not be defined in kube inputs

Avoid hitting KeyError Change-Id: I941bbbe1f647c9fdc887ed50b8ab30eaa4f21725 Closes-Bug: 1659436
Juniper · Jan 25, 2017 · 0e24aa1 · 0e24aa1
1 parent 1b9fb14
commit 0e24aa1
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 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
@@ -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
@@ -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')