openstack/deb-python-mistralclient
Code Issues Proposed changes

Adding changes related to Data Flow

Browse Source 
* This commit repeats changes of the commit
Ia0939e7099ae4386c1c3a761ac3892533eb3aed4 made in
core mistral repository.

Change-Id: I74b77d22ab6e7e5bde9015ab8b7ed7a02e7cfc45
This commit is contained in:
Renat Akhmerov
2014-01-23 16:11:53 -08:00
parent 4aa4fe1d56
commit 95e5ed89be
1 changed files with 20 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
mistralclient/tests/test_executions.py
View File

@@ -16,14 +16,22 @@
from mistralclient.tests import base
# TODO: later we need additional tests verifying all the errors etc.
# TODO: Later we need additional tests verifying all the errors etc.
EXECS = [
{
'id': "123",
'workbook_name': "my_workbook",
'target_task': 'my_task',
'state': 'RUNNING'
'state': 'RUNNING',
'context': """
{
"person": {
"first_name": "John",
"last_name": "Doe"
}
}
"""
}
]
@@ -33,14 +41,15 @@ class TestExecutions(base.BaseClientTest):
def test_create(self):
self.mock_http_post(json=EXECS[0])
wb = self.executions.create(EXECS[0]['workbook_name'],
ex = self.executions.create(EXECS[0]['workbook_name'],
EXECS[0]['target_task'])
self.assertIsNotNone(wb)
self.assertEqual(EXECS[0]['id'], wb.id)
self.assertEqual(EXECS[0]['workbook_name'], wb.workbook_name)
self.assertEqual(EXECS[0]['target_task'], wb.target_task)
self.assertEqual(EXECS[0]['state'], wb.state)
self.assertIsNotNone(ex)
self.assertEqual(EXECS[0]['id'], ex.id)
self.assertEqual(EXECS[0]['workbook_name'], ex.workbook_name)
self.assertEqual(EXECS[0]['target_task'], ex.target_task)
self.assertEqual(EXECS[0]['state'], ex.state)
self.assertEqual(EXECS[0]['context'], ex.context)
def test_update(self):
self.mock_http_put(json=EXECS[0])
@@ -54,6 +63,7 @@ class TestExecutions(base.BaseClientTest):
self.assertEqual(EXECS[0]['workbook_name'], ex.workbook_name)
self.assertEqual(EXECS[0]['target_task'], ex.target_task)
self.assertEqual(EXECS[0]['state'], ex.state)
self.assertEqual(EXECS[0]['context'], ex.context)
def test_list(self):
self.mock_http_get(json={'executions': EXECS})
@@ -68,6 +78,7 @@ class TestExecutions(base.BaseClientTest):
self.assertEqual(EXECS[0]['workbook_name'], ex.workbook_name)
self.assertEqual(EXECS[0]['target_task'], ex.target_task)
self.assertEqual(EXECS[0]['state'], ex.state)
self.assertEqual(EXECS[0]['context'], ex.context)
def test_get(self):
self.mock_http_get(json=EXECS[0])
@@ -78,6 +89,7 @@ class TestExecutions(base.BaseClientTest):
self.assertEqual(EXECS[0]['workbook_name'], ex.workbook_name)
self.assertEqual(EXECS[0]['target_task'], ex.target_task)
self.assertEqual(EXECS[0]['state'], ex.state)
self.assertEqual(EXECS[0]['context'], ex.context)
def test_delete(self):
self.mock_http_delete(status_code=204)