diff options
| author | Joshua Harlow <harlowja@yahoo-inc.com> | 2015-06-03 16:52:16 -0700 |
|---|---|---|
| committer | Joshua Harlow <harlowja@yahoo-inc.com> | 2015-06-03 17:07:03 -0700 |
| commit | abf21c728914ac2c2390efcce7dec4f19eb926a5 (patch) | |
| tree | 39305f0269f0955568a8d3e1d417603a73acf625 /taskflow/tests/unit/action_engine | |
| parent | 1e6b991b23c5e9f14562491915f0fa09b3ce8533 (diff) | |
| download | taskflow-abf21c728914ac2c2390efcce7dec4f19eb926a5.tar.gz | |
Refactor machine builder + runner into single unit
There is really no need to seperate off the runner into
a unit that builds a state-machine and then provides a tiny
utility function, both of these can just be in the same class
and code so that it is easier to understand/read.
Change-Id: I18b97514e230451ef804a878a0edcea4d0b2ad20
Diffstat (limited to 'taskflow/tests/unit/action_engine')
| -rw-r--r-- | taskflow/tests/unit/action_engine/test_runner.py | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/taskflow/tests/unit/action_engine/test_runner.py b/taskflow/tests/unit/action_engine/test_runner.py index 98ae0e2..cbc1e2e 100644 --- a/taskflow/tests/unit/action_engine/test_runner.py +++ b/taskflow/tests/unit/action_engine/test_runner.py @@ -174,7 +174,7 @@ class RunnerTest(test.TestCase, _RunnerTestMixin): rt.storage.get_atom_state(sad_tasks[0].name)) -class RunnerBuilderTest(test.TestCase, _RunnerTestMixin): +class RunnerBuildTest(test.TestCase, _RunnerTestMixin): def test_builder_manual_process(self): flow = lf.Flow("root") tasks = test_utils.make_many( @@ -182,8 +182,8 @@ class RunnerBuilderTest(test.TestCase, _RunnerTestMixin): flow.add(*tasks) rt = self._make_runtime(flow, initial_state=st.RUNNING) - machine, memory = rt.runner.builder.build() - self.assertTrue(rt.runner.builder.runnable()) + machine, memory = rt.runner.build() + self.assertTrue(rt.runner.runnable()) self.assertRaises(fsm.NotInitialized, machine.process_event, 'poke') # Should now be pending... @@ -251,8 +251,8 @@ class RunnerBuilderTest(test.TestCase, _RunnerTestMixin): flow.add(*tasks) rt = self._make_runtime(flow, initial_state=st.RUNNING) - machine, memory = rt.runner.builder.build() - self.assertTrue(rt.runner.builder.runnable()) + machine, memory = rt.runner.build() + self.assertTrue(rt.runner.runnable()) transitions = list(machine.run_iter('start')) self.assertEqual((runner._UNDEFINED, st.RESUMING), transitions[0]) @@ -265,8 +265,8 @@ class RunnerBuilderTest(test.TestCase, _RunnerTestMixin): flow.add(*tasks) rt = self._make_runtime(flow, initial_state=st.RUNNING) - machine, memory = rt.runner.builder.build() - self.assertTrue(rt.runner.builder.runnable()) + machine, memory = rt.runner.build() + self.assertTrue(rt.runner.runnable()) transitions = list(machine.run_iter('start')) self.assertEqual((runner._GAME_OVER, st.FAILURE), transitions[-1]) @@ -278,8 +278,8 @@ class RunnerBuilderTest(test.TestCase, _RunnerTestMixin): flow.add(*tasks) rt = self._make_runtime(flow, initial_state=st.RUNNING) - machine, memory = rt.runner.builder.build() - self.assertTrue(rt.runner.builder.runnable()) + machine, memory = rt.runner.build() + self.assertTrue(rt.runner.runnable()) transitions = list(machine.run_iter('start')) self.assertEqual((runner._GAME_OVER, st.REVERTED), transitions[-1]) @@ -292,7 +292,7 @@ class RunnerBuilderTest(test.TestCase, _RunnerTestMixin): flow.add(*tasks) rt = self._make_runtime(flow, initial_state=st.RUNNING) - machine, memory = rt.runner.builder.build() + machine, memory = rt.runner.build() transitions = list(machine.run_iter('start')) occurrences = dict((t, transitions.count(t)) for t in transitions) |