diff --git a/heat/rpc/worker_client.py b/heat/rpc/worker_client.py index 24d8fd64ed..5855ddfacb 100644 --- a/heat/rpc/worker_client.py +++ b/heat/rpc/worker_client.py @@ -46,4 +46,4 @@ class WorkerClient(object): client = self._client.prepare(version=version) else: client = self._client - return client.cast(ctxt, method, **kwargs) + client.cast(ctxt, method, **kwargs) diff --git a/heat/tests/test_rpc_worker_client.py b/heat/tests/test_rpc_worker_client.py index 75b25f1d70..182917bff9 100644 --- a/heat/tests/test_rpc_worker_client.py +++ b/heat/tests/test_rpc_worker_client.py @@ -58,14 +58,16 @@ class WorkerClientTest(common.HeatTestCase): msg = method, kwargs # go with default version - worker_client.cast(mock_cnxt, msg) + return_value = worker_client.cast(mock_cnxt, msg) + self.assertIsNone(return_value) mock_rpc_client.cast.assert_called_once_with(mock_cnxt, method, **kwargs) # Check cast in given version version = '1.2' - worker_client.cast(mock_cnxt, msg, version) + return_value = worker_client.cast(mock_cnxt, msg, version) + self.assertIsNone(return_value) mock_rpc_client.prepare.assert_called_once_with(version=version) mock_rpc_client.cast.assert_called_once_with(mock_cnxt, method,