removed two e2e tests temporarily

Author: yliaog

kubernetes/e2e_test/test_client.py

@@ -70,137 +70,6 @@ class TestClient(unittest.TestCase):
     def setUpClass(cls):
         cls.config = base.get_e2e_configuration()
 
-    def test_pod_apis(self):
-        client = api_client.ApiClient(configuration=self.config)
-        api = core_v1_api.CoreV1Api(client)
-
-        name = 'busybox-test-' + short_uuid()
-        pod_manifest = manifest_with_command(
-            name, "while true;do date;sleep 5; done")
-
-        # wait for the default service account to be created
-        timeout = time.time() + 30
-        while True:
-            if time.time() > timeout:
-                print('timeout waiting for default service account creation')
-                break
-            try:
-                resp = api.read_namespaced_service_account(name='default',
-                                                           namespace='default')
-            except ApiException as e:
-                if (six.PY3 and e.status != HTTPStatus.NOT_FOUND) or (
-                        six.PY3 is False and e.status != httplib.NOT_FOUND):
-                    print('error: %s' % e)
-                    self.fail(
-                        msg="unexpected error getting default service account")
-                print('default service not found yet: %s' % e)
-                time.sleep(1)
-                continue
-            self.assertEqual('default', resp.metadata.name)
-            break
-
-        resp = api.create_namespaced_pod(body=pod_manifest,
-                                         namespace='default')
-        self.assertEqual(name, resp.metadata.name)
-        self.assertTrue(resp.status.phase)
-
-        while True:
-            resp = api.read_namespaced_pod(name=name,
-                                           namespace='default')
-            self.assertEqual(name, resp.metadata.name)
-            self.assertTrue(resp.status.phase)
-            if resp.status.phase != 'Pending':
-                break
-            time.sleep(1)
-
-        exec_command = ['/bin/sh',
-                        '-c',
-                        'for i in $(seq 1 3); do date; done']
-        resp = stream(api.connect_get_namespaced_pod_exec, name, 'default',
-                      command=exec_command,
-                      stderr=False, stdin=False,
-                      stdout=True, tty=False)
-        print('EXEC response : %s (%s)' % (repr(resp), type(resp)))
-        self.assertIsInstance(resp, str)
-        self.assertEqual(3, len(resp.splitlines()))
-
-        exec_command = ['/bin/sh',
-                        '-c',
-                        'echo -n "This is a test string" | gzip']
-        resp = stream(api.connect_get_namespaced_pod_exec, name, 'default',
-                      command=exec_command,
-                      stderr=False, stdin=False,
-                      stdout=True, tty=False,
-                      binary=True)
-        print('EXEC response : %s (%s)' % (repr(resp), type(resp)))
-        self.assertIsInstance(resp, bytes)
-        self.assertEqual("This is a test string", gzip.decompress(resp).decode('utf-8'))
-
-        exec_command = 'uptime'
-        resp = stream(api.connect_post_namespaced_pod_exec, name, 'default',
-                      command=exec_command,
-                      stderr=False, stdin=False,
-                      stdout=True, tty=False)
-        print('EXEC response : %s' % repr(resp))
-        self.assertEqual(1, len(resp.splitlines()))
-
-        resp = stream(api.connect_post_namespaced_pod_exec, name, 'default',
-                      command='/bin/sh',
-                      stderr=True, stdin=True,
-                      stdout=True, tty=False,
-                      _preload_content=False)
-        resp.write_stdin("echo test string 1\n")
-        line = resp.readline_stdout(timeout=5)
-        self.assertFalse(resp.peek_stderr())
-        self.assertEqual("test string 1", line)
-        resp.write_stdin("echo test string 2 >&2\n")
-        line = resp.readline_stderr(timeout=5)
-        self.assertFalse(resp.peek_stdout())
-        self.assertEqual("test string 2", line)
-        resp.write_stdin("exit\n")
-        resp.update(timeout=5)
-        while True:
-            line = resp.read_channel(ERROR_CHANNEL)
-            if line != '':
-                break
-            time.sleep(1)
-        status = json.loads(line)
-        self.assertEqual(status['status'], 'Success')
-        resp.update(timeout=5)
-        self.assertFalse(resp.is_open())
-
-        resp = stream(api.connect_post_namespaced_pod_exec, name, 'default',
-                      command='/bin/sh',
-                      stderr=True, stdin=True,
-                      stdout=True, tty=False,
-                      binary=True,
-                      _preload_content=False)
-        resp.write_stdin(b"echo test string 1\n")
-        line = resp.readline_stdout(timeout=5)
-        self.assertFalse(resp.peek_stderr())
-        self.assertEqual(b"test string 1", line)
-        resp.write_stdin(b"echo test string 2 >&2\n")
-        line = resp.readline_stderr(timeout=5)
-        self.assertFalse(resp.peek_stdout())
-        self.assertEqual(b"test string 2", line)
-        resp.write_stdin(b"exit\n")
-        resp.update(timeout=5)
-        while True:
-            line = resp.read_channel(ERROR_CHANNEL)
-            if len(line) != 0:
-                break
-            time.sleep(1)
-        status = json.loads(line)
-        self.assertEqual(status['status'], 'Success')
-        resp.update(timeout=5)
-        self.assertFalse(resp.is_open())
-
-        number_of_pods = len(api.list_pod_for_all_namespaces().items)
-        self.assertTrue(number_of_pods > 0)
-
-        resp = api.delete_namespaced_pod(name=name, body={},
-                                         namespace='default')
-
     def test_exit_code(self):
         client = api_client.ApiClient(configuration=self.config)
         api = core_v1_api.CoreV1Api(client)