diff options
author | Zuul <zuul@review.opendev.org> | 2023-03-06 08:03:28 +0000 |
---|---|---|
committer | Gerrit Code Review <review@openstack.org> | 2023-03-06 08:03:28 +0000 |
commit | ac53891e85d76851ed628a541b414acd43fb0c7b (patch) | |
tree | 9c41a5df6f96c5c81f45e1205bedc34fc044b7b4 | |
parent | 7e08f5b9dc48bf769da5edbfd4cfdbbde85f9b47 (diff) | |
parent | c31eb4f5c708b7298edd020512d3be3038868625 (diff) | |
download | heat-ac53891e85d76851ed628a541b414acd43fb0c7b.tar.gz |
Merge "fix heat update senlin cluster"
-rw-r--r-- | heat/engine/resources/openstack/senlin/cluster.py | 8 | ||||
-rw-r--r-- | heat/tests/openstack/senlin/test_cluster.py | 4 |
2 files changed, 6 insertions, 6 deletions
diff --git a/heat/engine/resources/openstack/senlin/cluster.py b/heat/engine/resources/openstack/senlin/cluster.py index 02c59fa64..6d68bb919 100644 --- a/heat/engine/resources/openstack/senlin/cluster.py +++ b/heat/engine/resources/openstack/senlin/cluster.py @@ -322,11 +322,11 @@ class Cluster(res_base.BaseSenlinResource): params['cluster'] = cluster_obj if self.PROFILE in params: params['profile_id'] = params.pop(self.PROFILE) + + self.client().update_cluster(**params) action = { - 'func': 'update_cluster', - 'params': params, - 'action_id': None, - 'done': False, + 'cluster_id': self.resource_id, + 'done': False } actions.append(action) # Resize Cluster diff --git a/heat/tests/openstack/senlin/test_cluster.py b/heat/tests/openstack/senlin/test_cluster.py index 32b39fb54..5a451801c 100644 --- a/heat/tests/openstack/senlin/test_cluster.py +++ b/heat/tests/openstack/senlin/test_cluster.py @@ -196,7 +196,7 @@ class SenlinClusterTest(common.HeatTestCase): rsrc_defns = template.Template(new_t).resource_definitions(self.stack) new_cluster = rsrc_defns['senlin-cluster'] self.senlin_mock.update_cluster.return_value = mock.Mock( - location='/actions/fake-action') + cluster=new_cluster) self.senlin_mock.get_action.return_value = mock.Mock( status='SUCCEEDED') scheduler.TaskRunner(cluster.update, new_cluster)() @@ -207,7 +207,7 @@ class SenlinClusterTest(common.HeatTestCase): } self.senlin_mock.update_cluster.assert_called_once_with( cluster=self.fake_cl, **cluster_update_kwargs) - self.assertEqual(2, self.senlin_mock.get_action.call_count) + self.assertEqual(1, self.senlin_mock.get_action.call_count) def test_cluster_update_desire_capacity(self): cluster = self._create_cluster(self.t) |