Merge "Revert "compute/server: add support of target state for evacuate API""
This commit is contained in:
@@ -969,8 +969,7 @@ class Proxy(proxy.Proxy):
|
||||
server = self._get_resource(_server.Server, server)
|
||||
server.unrescue(self)
|
||||
|
||||
def evacuate_server(self, server, host=None, admin_pass=None, force=None,
|
||||
target_state=None):
|
||||
def evacuate_server(self, server, host=None, admin_pass=None, force=None):
|
||||
"""Evacuates a server from a failed host to a new host.
|
||||
|
||||
:param server: Either the ID of a server or a
|
||||
@@ -982,13 +981,11 @@ class Proxy(proxy.Proxy):
|
||||
:param force: Force an evacuation by not verifying the provided
|
||||
destination host by the scheduler. (New in API version
|
||||
2.29).
|
||||
:param target_state: Set target state for the evacuated instance (New
|
||||
in API version 2.94).
|
||||
:returns: None
|
||||
"""
|
||||
server = self._get_resource(_server.Server, server)
|
||||
server.evacuate(self, host=host, admin_pass=admin_pass,
|
||||
force=force, target_state=target_state)
|
||||
force=force)
|
||||
|
||||
def start_server(self, server):
|
||||
"""Starts a stopped server and changes its state to ``ACTIVE``.
|
||||
|
||||
@@ -459,8 +459,7 @@ class Server(resource.Resource, metadata.MetadataMixin, tag.TagMixin):
|
||||
body = {"unrescue": None}
|
||||
self._action(session, body)
|
||||
|
||||
def evacuate(self, session, host=None, admin_pass=None, force=None,
|
||||
target_state=None):
|
||||
def evacuate(self, session, host=None, admin_pass=None, force=None):
|
||||
body = {"evacuate": {}}
|
||||
if host is not None:
|
||||
body["evacuate"]["host"] = host
|
||||
@@ -468,8 +467,6 @@ class Server(resource.Resource, metadata.MetadataMixin, tag.TagMixin):
|
||||
body["evacuate"]["adminPass"] = admin_pass
|
||||
if force is not None:
|
||||
body["evacuate"]["force"] = force
|
||||
if target_state is not None:
|
||||
body["evacuate"]["targetState"] = target_state
|
||||
self._action(session, body)
|
||||
|
||||
def start(self, session):
|
||||
|
||||
@@ -1041,18 +1041,16 @@ class TestCompute(TestComputeProxy):
|
||||
self.proxy.evacuate_server,
|
||||
method_args=["value"],
|
||||
expected_args=[self.proxy],
|
||||
expected_kwargs={"host": None, "admin_pass": None, "force": None,
|
||||
"target_state": None})
|
||||
expected_kwargs={"host": None, "admin_pass": None, "force": None})
|
||||
|
||||
def test_server_evacuate_with_options(self):
|
||||
self._verify(
|
||||
"openstack.compute.v2.server.Server.evacuate",
|
||||
self.proxy.evacuate_server,
|
||||
method_args=["value", 'HOST2', 'NEW_PASS', True, 'stopped'],
|
||||
method_args=["value", 'HOST2', 'NEW_PASS', True],
|
||||
expected_args=[self.proxy],
|
||||
expected_kwargs={
|
||||
"host": "HOST2", "admin_pass": 'NEW_PASS', "force": True,
|
||||
"target_state": 'stopped'})
|
||||
"host": "HOST2", "admin_pass": 'NEW_PASS', "force": True})
|
||||
|
||||
def test_server_start(self):
|
||||
self._verify(
|
||||
|
||||
@@ -735,12 +735,12 @@ class TestServer(base.TestCase):
|
||||
sot = server.Server(**EXAMPLE)
|
||||
|
||||
res = sot.evacuate(self.sess, host='HOST2', admin_pass='NEW_PASS',
|
||||
force=True, target_state='stopped')
|
||||
force=True)
|
||||
|
||||
self.assertIsNone(res)
|
||||
url = 'servers/IDENTIFIER/action'
|
||||
body = {"evacuate": {'host': 'HOST2', 'adminPass': 'NEW_PASS',
|
||||
'force': True, 'targetState': 'stopped'}}
|
||||
'force': True}}
|
||||
headers = {'Accept': ''}
|
||||
self.sess.post.assert_called_with(
|
||||
url, json=body, headers=headers, microversion=None)
|
||||
|
||||
@@ -1,3 +0,0 @@
|
||||
---
|
||||
features:
|
||||
- Add support of setting target state for evacuate API.
|
||||
Reference in New Issue
Block a user