fixed watch_test, event is a dict, not an object

Author: yliaog

kubernetes/base/watch/watch_test.py

@@ -52,10 +52,10 @@ def test_watch_with_decode(self):
         for e in w.stream(fake_api.get_namespaces):
             self.assertEqual("ADDED", e['type'])
             # make sure decoder worked and we got a model with the right name
-            self.assertEqual("test%d" % count, e['object'].metadata.name)
+            self.assertEqual("test%d" % count, e['object']['metadata']['name'])
             # make sure decoder worked and updated Watch.resource_version
             self.assertEqual(
-                "%d" % count, e['object'].metadata.resource_version)
+                "%d" % count, e['object']['metadata']['resourceVersion'])
             self.assertEqual("%d" % count, w.resource_version)
             count += 1
             # make sure we can stop the watch and the last event with won't be
@@ -105,7 +105,7 @@ def test_watch_with_interspersed_newlines(self):
             if e is None:
                 continue
             count += 1
-            self.assertEqual("test%d" % count, e['object'].metadata.name)
+            self.assertEqual("test%d" % count, e['object']['metadata']['name'])
         self.assertEqual(3, count)
 
     def test_watch_with_multibyte_utf8(self):
@@ -140,10 +140,10 @@ def test_watch_with_multibyte_utf8(self):
         for event in w.stream(fake_api.get_configmaps, timeout_seconds=1):
             count += 1
             self.assertEqual("MODIFIED", event['type'])
-            self.assertEqual("test%d" % count, event['object'].metadata.name)
-            self.assertEqual("© %d" % count, event['object'].data["utf-8"])
+            self.assertEqual("test%d" % count, event['object']['metadata']['name'])
+            self.assertEqual("© %d" % count, event['object']['data']["utf-8"])
             self.assertEqual(
-                "%d" % count, event['object'].metadata.resource_version)
+                "%d" % count, event['object']['metadata']['resourceVersion'])
             self.assertEqual("%d" % count, w.resource_version)
         self.assertEqual(3, count)
 
@@ -186,11 +186,11 @@ def test_watch_with_invalid_utf8(self):
         for event in w.stream(fake_api.get_configmaps, timeout_seconds=1):
             count += 1
             self.assertEqual("MODIFIED", event['type'])
-            self.assertEqual("test%d" % count, event['object'].metadata.name)
-            self.assertEqual("😄 %d" % count, event['object'].data["utf-8"])
+            self.assertEqual("test%d" % count, event['object']['metadata']['name'])
+            self.assertEqual("😄 %d" % count, event['object']['data']["utf-8"])
             # expect N replacement characters in test N
             self.assertEqual("� %d".replace('�', '�'*count) %
-                             count, event['object'].data["invalid"])
+                             count, event['object']['data']["invalid"])
         self.assertEqual(3, count)
 
     def test_watch_for_follow(self):