summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorricolin <rico.lin@easystack.cn>2018-04-01 22:48:35 +0800
committerricolin <rico.lin@easystack.cn>2018-04-01 22:48:35 +0800
commit1e3ddf11ffa88dbd334aec8db3168a0e1830e662 (patch)
tree71063233947b83fa0db9187865bdb632e63bcdc0
parentd00a068c5b49fb7bf8e774a0bda37a5047c33614 (diff)
downloadheat-1e3ddf11ffa88dbd334aec8db3168a0e1830e662.tar.gz
Remove mox usage from test_docker_container
Change-Id: I331dfd937efad0dafed3aaa29b2d5a3d9741a4a6 goal: mox-removal
-rw-r--r--contrib/heat_docker/heat_docker/tests/test_docker_container.py40
1 files changed, 16 insertions, 24 deletions
diff --git a/contrib/heat_docker/heat_docker/tests/test_docker_container.py b/contrib/heat_docker/heat_docker/tests/test_docker_container.py
index 45f940b76..a183723dc 100644
--- a/contrib/heat_docker/heat_docker/tests/test_docker_container.py
+++ b/contrib/heat_docker/heat_docker/tests/test_docker_container.py
@@ -59,7 +59,6 @@ class DockerContainerTest(common.HeatTestCase):
super(DockerContainerTest, self).setUp()
for res_name, res_class in docker_container.resource_mapping().items():
resource._register_class(res_name, res_class)
- self.addCleanup(self.m.VerifyAll)
def create_container(self, resource_name):
t = template_format.parse(template)
@@ -68,11 +67,9 @@ class DockerContainerTest(common.HeatTestCase):
resource_name,
self.stack.t.resource_definitions(self.stack)[resource_name],
self.stack)
- self.m.StubOutWithMock(resource, 'get_client')
- resource.get_client().MultipleTimes().AndReturn(
- docker.Client())
+ self.patchobject(resource, 'get_client',
+ return_value=docker.Client())
self.assertIsNone(resource.validate())
- self.m.ReplayAll()
scheduler.TaskRunner(resource.create)()
self.assertEqual((resource.CREATE, resource.COMPLETE),
resource.state)
@@ -99,11 +96,9 @@ class DockerContainerTest(common.HeatTestCase):
props['name'] = 'super-blog'
resource = docker_container.DockerContainer(
'Blog', definition.freeze(properties=props), self.stack)
- self.m.StubOutWithMock(resource, 'get_client')
- resource.get_client().MultipleTimes().AndReturn(
- docker.Client())
+ self.patchobject(resource, 'get_client',
+ return_value=docker.Client())
self.assertIsNone(resource.validate())
- self.m.ReplayAll()
scheduler.TaskRunner(resource.create)()
self.assertEqual((resource.CREATE, resource.COMPLETE),
resource.state)
@@ -142,11 +137,9 @@ class DockerContainerTest(common.HeatTestCase):
props['links'] = {'db': 'mysql'}
resource = docker_container.DockerContainer(
'Blog', definition.freeze(properties=props), self.stack)
- self.m.StubOutWithMock(resource, 'get_client')
- resource.get_client().MultipleTimes().AndReturn(
- docker.Client())
+ self.patchobject(resource, 'get_client',
+ return_value=docker.Client())
self.assertIsNone(resource.validate())
- self.m.ReplayAll()
scheduler.TaskRunner(resource.create)()
self.assertEqual((resource.CREATE, resource.COMPLETE),
resource.state)
@@ -188,7 +181,6 @@ class DockerContainerTest(common.HeatTestCase):
raise
self.assertIs(False, exists)
- self.m.VerifyAll()
@testtools.skipIf(docker is None, 'docker-py not available')
def test_resource_delete_exception(self):
@@ -197,18 +189,18 @@ class DockerContainerTest(common.HeatTestCase):
response.content = 'some content'
container = self.create_container('Blog')
- self.m.StubOutWithMock(container.get_client(), 'kill')
- container.get_client().kill(container.resource_id).AndRaise(
- docker.errors.APIError('Not found', response))
-
- self.m.StubOutWithMock(container, '_get_container_status')
- container._get_container_status(container.resource_id).AndRaise(
- docker.errors.APIError('Not found', response))
-
- self.m.ReplayAll()
+ self.patchobject(container.get_client(), 'kill',
+ side_effect=[docker.errors.APIError(
+ 'Not found', response)])
+ self.patchobject(container, '_get_container_status',
+ side_effect=[docker.errors.APIError(
+ 'Not found', response)])
scheduler.TaskRunner(container.delete)()
- self.m.VerifyAll()
+ container.get_client().kill.assert_called_once_with(
+ container.resource_id)
+ container._get_container_status.assert_called_once_with(
+ container.resource_id)
def test_resource_suspend_resume(self):
container = self.create_container('Blog')