d3c129270a
* In list representation it doesn't make a lot of sense to show state info (even in shrinked form) because one will be looking at it most likely if state is not SUCCESS, individually for every action execution object. Removing this field though allows to represent this table in a more consistent form. Change-Id: Iee5aabf386b79fdc8aaca7528d22a4675dd303a4
155 lines
4.6 KiB
Python
155 lines
4.6 KiB
Python
# Copyright 2014 Mirantis, Inc.
|
|
# All Rights Reserved
|
|
#
|
|
# Licensed under the Apache License, Version 2.0 (the "License"); you may
|
|
# not use this file except in compliance with the License. You may obtain
|
|
# a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
|
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
|
# License for the specific language governing permissions and limitations
|
|
# under the License.
|
|
#
|
|
|
|
import json
|
|
|
|
import mock
|
|
|
|
from mistralclient.api.v2 import action_executions as action_ex
|
|
from mistralclient.commands.v2 import action_executions as action_ex_cmd
|
|
from mistralclient.tests.unit import base
|
|
|
|
ACTION_EX_DICT = {
|
|
'id': '123',
|
|
'name': 'some',
|
|
'workflow_name': 'thing',
|
|
'task_name': 'task1',
|
|
'task_execution_id': "1-2-3-4",
|
|
'state': 'RUNNING',
|
|
'state_info': 'RUNNING somehow.',
|
|
'accepted': True
|
|
}
|
|
|
|
ACTION_EX_RESULT = {"test": "is", "passed": "successfully"}
|
|
ACTION_EX_INPUT = {"param1": "val1", "param2": 2}
|
|
|
|
ACTION_EX_WITH_OUTPUT_DICT = ACTION_EX_DICT.copy()
|
|
ACTION_EX_WITH_OUTPUT_DICT.update({'output': json.dumps(ACTION_EX_RESULT)})
|
|
|
|
ACTION_EX_WITH_INPUT_DICT = ACTION_EX_DICT.copy()
|
|
ACTION_EX_WITH_INPUT_DICT.update({'input': json.dumps(ACTION_EX_INPUT)})
|
|
|
|
ACTION_EX = action_ex.ActionExecution(mock, ACTION_EX_DICT)
|
|
ACTION_EX_WITH_OUTPUT = action_ex.ActionExecution(
|
|
mock,
|
|
ACTION_EX_WITH_OUTPUT_DICT
|
|
)
|
|
ACTION_EX_WITH_INPUT = action_ex.ActionExecution(
|
|
mock,
|
|
ACTION_EX_WITH_INPUT_DICT
|
|
)
|
|
|
|
|
|
class TestCLIActionExecutions(base.BaseCommandTest):
|
|
def test_create(self):
|
|
(self.client.action_executions.create.
|
|
return_value) = ACTION_EX_WITH_OUTPUT
|
|
|
|
self.call(
|
|
action_ex_cmd.Create,
|
|
app_args=['some', '{"output": "Hello!"}']
|
|
)
|
|
|
|
self.assertDictEqual(
|
|
ACTION_EX_RESULT,
|
|
json.loads(self.app.stdout.write.call_args[0][0])
|
|
)
|
|
|
|
def test_create_save_result(self):
|
|
(self.client.action_executions.create.
|
|
return_value) = ACTION_EX_WITH_OUTPUT
|
|
|
|
result = self.call(
|
|
action_ex_cmd.Create,
|
|
app_args=[
|
|
'some', '{"output": "Hello!"}', '--save-result'
|
|
]
|
|
)
|
|
|
|
self.assertEqual(
|
|
('123', 'some', 'thing', 'task1', '1-2-3-4', 'RUNNING',
|
|
'RUNNING somehow.', True),
|
|
result[1]
|
|
)
|
|
|
|
def test_update(self):
|
|
self.client.action_executions.update.return_value = ACTION_EX
|
|
|
|
result = self.call(
|
|
action_ex_cmd.Update,
|
|
app_args=['id', '--state', 'ERROR']
|
|
)
|
|
|
|
self.assertEqual(
|
|
('123', 'some', 'thing', 'task1', '1-2-3-4', 'RUNNING',
|
|
'RUNNING somehow.', True),
|
|
result[1]
|
|
)
|
|
|
|
def test_list(self):
|
|
self.client.action_executions.list.return_value = [ACTION_EX]
|
|
|
|
result = self.call(action_ex_cmd.List)
|
|
|
|
self.assertEqual(
|
|
[('123', 'some', 'thing', 'task1', '1-2-3-4', 'RUNNING', True)],
|
|
result[1]
|
|
)
|
|
|
|
def test_get(self):
|
|
self.client.action_executions.get.return_value = ACTION_EX
|
|
|
|
result = self.call(action_ex_cmd.Get, app_args=['id'])
|
|
|
|
self.assertEqual(
|
|
('123', 'some', 'thing', 'task1', '1-2-3-4', 'RUNNING',
|
|
'RUNNING somehow.', True), result[1]
|
|
)
|
|
|
|
def test_get_output(self):
|
|
self.client.action_executions.get.return_value = ACTION_EX_WITH_OUTPUT
|
|
|
|
self.call(action_ex_cmd.GetOutput, app_args=['id'])
|
|
|
|
self.assertDictEqual(
|
|
ACTION_EX_RESULT,
|
|
json.loads(self.app.stdout.write.call_args[0][0])
|
|
)
|
|
|
|
def test_get_input(self):
|
|
self.client.action_executions.get.return_value = ACTION_EX_WITH_INPUT
|
|
|
|
self.call(action_ex_cmd.GetInput, app_args=['id'])
|
|
|
|
self.assertDictEqual(
|
|
ACTION_EX_INPUT,
|
|
json.loads(self.app.stdout.write.call_args[0][0])
|
|
)
|
|
|
|
def test_delete(self):
|
|
self.call(action_ex_cmd.Delete, app_args=['id'])
|
|
|
|
self.client.action_executions.delete.assert_called_once_with('id')
|
|
|
|
def test_delete_with_multi_names(self):
|
|
self.call(action_ex_cmd.Delete, app_args=['id1', 'id2'])
|
|
|
|
self.assertEqual(2, self.client.action_executions.delete.call_count)
|
|
self.assertEqual(
|
|
[mock.call('id1'), mock.call('id2')],
|
|
self.client.action_executions.delete.call_args_list
|
|
)
|