Merge "Add new tempest tests for swift and zaqar client actions"
This commit is contained in:
commit
0d2196fc61
|
@ -51,3 +51,25 @@ workflows:
|
||||||
publish:
|
publish:
|
||||||
result: <% task().result %>
|
result: <% task().result %>
|
||||||
|
|
||||||
|
swift:
|
||||||
|
type: direct
|
||||||
|
tasks:
|
||||||
|
get_account:
|
||||||
|
action: swift.get_account
|
||||||
|
publish:
|
||||||
|
result: <% task().result %>
|
||||||
|
|
||||||
|
zaqar:
|
||||||
|
type: direct
|
||||||
|
tasks:
|
||||||
|
send_message:
|
||||||
|
action: zaqar.queue_post
|
||||||
|
input:
|
||||||
|
queue_name: test
|
||||||
|
messages:
|
||||||
|
body:
|
||||||
|
type: action_collection.zaqar
|
||||||
|
payload:
|
||||||
|
status: <% $.get(status, 'SUCCESS') %>
|
||||||
|
publish:
|
||||||
|
result: <% task().result %>
|
||||||
|
|
|
@ -90,3 +90,23 @@ class OpenStackActionsTestsV2(base.TestCase):
|
||||||
executed_task = self.client.get_wf_tasks(wf_name)[-1]
|
executed_task = self.client.get_wf_tasks(wf_name)[-1]
|
||||||
|
|
||||||
self.assertEqual('SUCCESS', executed_task['state'])
|
self.assertEqual('SUCCESS', executed_task['state'])
|
||||||
|
|
||||||
|
@decorators.attr(type='openstack')
|
||||||
|
@decorators.idempotent_id('985c1051-cf2e-4fd0-8ceb-a9b8110597a1')
|
||||||
|
def test_swift_actions(self):
|
||||||
|
wf_name = self.wb['name'] + '.swift'
|
||||||
|
_, execution = self.client.create_execution(wf_name)
|
||||||
|
self.client.wait_execution_success(execution)
|
||||||
|
executed_task = self.client.get_wf_tasks(wf_name)[-1]
|
||||||
|
|
||||||
|
self.assertEqual('SUCCESS', executed_task['state'])
|
||||||
|
|
||||||
|
@decorators.attr(type='openstack')
|
||||||
|
@decorators.idempotent_id('6f000ae8-3f41-49bd-b7a7-ad2256d80076')
|
||||||
|
def test_zaqar_actions(self):
|
||||||
|
wf_name = self.wb['name'] + '.zaqar'
|
||||||
|
_, execution = self.client.create_execution(wf_name)
|
||||||
|
self.client.wait_execution_success(execution)
|
||||||
|
executed_task = self.client.get_wf_tasks(wf_name)[-1]
|
||||||
|
|
||||||
|
self.assertEqual('SUCCESS', executed_task['state'])
|
||||||
|
|
Loading…
Reference in New Issue