Remove the delay from the direct workflow rerun tests
The 10 second delay was overly generous. This change reduces the test run time by around 25-30 seconds. Related-Bug: #1669511 Change-Id: I55ded366162b4124f795c341d4bae919b09f468e
This commit is contained in:
parent
91237c2baa
commit
6eef45a775
@ -559,7 +559,7 @@ class DirectWorkflowRerunTest(base.EngineTestCase):
|
|||||||
self.assertEqual(states.RUNNING, wf_ex.state)
|
self.assertEqual(states.RUNNING, wf_ex.state)
|
||||||
self.assertIsNone(wf_ex.state_info)
|
self.assertIsNone(wf_ex.state_info)
|
||||||
|
|
||||||
self.await_workflow_success(wf_ex.id, delay=10)
|
self.await_workflow_success(wf_ex.id)
|
||||||
|
|
||||||
with db_api.transaction():
|
with db_api.transaction():
|
||||||
wf_ex = db_api.get_workflow_execution(wf_ex.id)
|
wf_ex = db_api.get_workflow_execution(wf_ex.id)
|
||||||
@ -646,7 +646,7 @@ class DirectWorkflowRerunTest(base.EngineTestCase):
|
|||||||
self.assertEqual(states.RUNNING, wf_ex.state)
|
self.assertEqual(states.RUNNING, wf_ex.state)
|
||||||
self.assertIsNone(wf_ex.state_info)
|
self.assertIsNone(wf_ex.state_info)
|
||||||
|
|
||||||
self.await_workflow_success(wf_ex.id, delay=10)
|
self.await_workflow_success(wf_ex.id)
|
||||||
|
|
||||||
wf_ex = db_api.get_workflow_execution(wf_ex.id)
|
wf_ex = db_api.get_workflow_execution(wf_ex.id)
|
||||||
|
|
||||||
@ -739,7 +739,7 @@ class DirectWorkflowRerunTest(base.EngineTestCase):
|
|||||||
self.assertEqual(states.RUNNING, wf_ex.state)
|
self.assertEqual(states.RUNNING, wf_ex.state)
|
||||||
self.assertIsNone(wf_ex.state_info)
|
self.assertIsNone(wf_ex.state_info)
|
||||||
|
|
||||||
self.await_workflow_success(wf_ex.id, delay=10)
|
self.await_workflow_success(wf_ex.id)
|
||||||
|
|
||||||
with db_api.transaction():
|
with db_api.transaction():
|
||||||
wf_ex = db_api.get_workflow_execution(wf_ex.id)
|
wf_ex = db_api.get_workflow_execution(wf_ex.id)
|
||||||
@ -1088,7 +1088,7 @@ class DirectWorkflowRerunTest(base.EngineTestCase):
|
|||||||
self.assertEqual(states.RUNNING, wf_ex.state)
|
self.assertEqual(states.RUNNING, wf_ex.state)
|
||||||
self.assertIsNone(wf_ex.state_info)
|
self.assertIsNone(wf_ex.state_info)
|
||||||
|
|
||||||
self.await_workflow_error(wf_ex.id, delay=10)
|
self.await_workflow_error(wf_ex.id)
|
||||||
|
|
||||||
wf_ex = db_api.get_workflow_execution(wf_ex.id)
|
wf_ex = db_api.get_workflow_execution(wf_ex.id)
|
||||||
|
|
||||||
@ -1109,7 +1109,7 @@ class DirectWorkflowRerunTest(base.EngineTestCase):
|
|||||||
self.assertEqual(states.RUNNING, wf_ex.state)
|
self.assertEqual(states.RUNNING, wf_ex.state)
|
||||||
self.assertIsNone(wf_ex.state_info)
|
self.assertIsNone(wf_ex.state_info)
|
||||||
|
|
||||||
self.await_workflow_error(wf_ex.id, delay=10)
|
self.await_workflow_error(wf_ex.id)
|
||||||
|
|
||||||
wf_ex = db_api.get_workflow_execution(wf_ex.id)
|
wf_ex = db_api.get_workflow_execution(wf_ex.id)
|
||||||
|
|
||||||
@ -1130,7 +1130,7 @@ class DirectWorkflowRerunTest(base.EngineTestCase):
|
|||||||
self.assertEqual(states.RUNNING, wf_ex.state)
|
self.assertEqual(states.RUNNING, wf_ex.state)
|
||||||
self.assertIsNone(wf_ex.state_info)
|
self.assertIsNone(wf_ex.state_info)
|
||||||
|
|
||||||
self.await_workflow_error(wf_ex.id, delay=10)
|
self.await_workflow_error(wf_ex.id)
|
||||||
|
|
||||||
wf_ex = db_api.get_workflow_execution(wf_ex.id)
|
wf_ex = db_api.get_workflow_execution(wf_ex.id)
|
||||||
|
|
||||||
@ -1151,7 +1151,7 @@ class DirectWorkflowRerunTest(base.EngineTestCase):
|
|||||||
self.assertEqual(states.RUNNING, wf_ex.state)
|
self.assertEqual(states.RUNNING, wf_ex.state)
|
||||||
self.assertIsNone(wf_ex.state_info)
|
self.assertIsNone(wf_ex.state_info)
|
||||||
|
|
||||||
self.await_workflow_success(wf_ex.id, delay=10)
|
self.await_workflow_success(wf_ex.id)
|
||||||
|
|
||||||
with db_api.transaction():
|
with db_api.transaction():
|
||||||
wf_ex = db_api.get_workflow_execution(wf_ex.id)
|
wf_ex = db_api.get_workflow_execution(wf_ex.id)
|
||||||
|
Loading…
Reference in New Issue
Block a user