We are content to announce the release of: taskflow 1.17.0: Taskflow structured state management library. This release is part of the liberty release series. With source available at: http://git.openstack.org/cgit/openstack/taskflow With package available at: https://pypi.python.org/pypi/taskflow For more details, please see the git log history below and: http://launchpad.net/taskflow/+milestone/1.17.0 Please report issues through launchpad: http://bugs.launchpad.net/taskflow/ Changes in taskflow 1.16.0..1.17.0 ---------------------------------- 9ad7ec6 Modify listeners to handle the results now possible from revert() 16d9914 Updated from global requirements 7e1d330 Fix lack of space between functions 359cc49 Create and use a serial retry executor e5092b6 Just link to the worker engine docs instead of including a TOC inline 5bbf8cf Link to run() method in engines doc 58fbfd0 Add ability to reset an engine via a `reset` method 02c83d4 Remove **most** usage of taskflow.utils in examples 7bc1be0 Unify the zookeeper/redis jobboard iterators e004197 Use io.open vs raw open 14de80d Make currently implemented jobs use @functools.total_ordering 0d884a2 Use encodeutils for exception -> string function db7af3f Remove kazoo hack/fix for issue no longer needed 3e16e24 Update states comment to refer to task section 9e6ef18 Document more of the retry subclasses special keyword arguments Diffstat (except docs and test files) ------------------------------------- requirements.txt | 2 +- taskflow/engines/action_engine/actions/base.py | 16 ++ taskflow/engines/action_engine/actions/retry.py | 66 +++----- taskflow/engines/action_engine/actions/task.py | 6 +- taskflow/engines/action_engine/completer.py | 11 +- taskflow/engines/action_engine/engine.py | 37 +++-- taskflow/engines/action_engine/executor.py | 48 +++++- taskflow/engines/action_engine/runner.py | 3 +- taskflow/engines/action_engine/runtime.py | 10 +- taskflow/engines/action_engine/scheduler.py | 6 +- taskflow/engines/base.py | 15 +- taskflow/examples/dump_memory_backend.py | 14 +- taskflow/examples/hello_world.py | 14 +- taskflow/examples/parallel_table_multiply.py | 6 +- taskflow/examples/persistence_example.py | 3 +- taskflow/examples/resume_from_backend.py | 31 ++-- taskflow/examples/resume_vm_boot.py | 18 ++- taskflow/examples/resume_volume_create.py | 13 +- taskflow/examples/run_by_iter.py | 7 +- taskflow/examples/run_by_iter_enumerate.py | 7 +- taskflow/examples/switch_graph_flow.py | 12 +- taskflow/exceptions.py | 33 ++-- taskflow/jobs/backends/impl_redis.py | 64 +++++--- taskflow/jobs/backends/impl_zookeeper.py | 95 +++-------- taskflow/jobs/base.py | 73 +++++++++ taskflow/listeners/base.py | 8 +- taskflow/listeners/logging.py | 26 +-- taskflow/persistence/backends/impl_dir.py | 8 +- taskflow/persistence/models.py | 94 +++++++++++ taskflow/retry.py | 39 ++++- taskflow/states.py | 1 + taskflow/types/failure.py | 12 +- taskflow/utils/kazoo_utils.py | 8 +- taskflow/utils/mixins.py | 35 ++++ taskflow/utils/persistence_utils.py | 75 --------- test-requirements.txt | 3 +- 45 files changed, 776 insertions(+), 427 deletions(-) Requirements updates -------------------- diff --git a/requirements.txt b/requirements.txt index 4c9740c..7ae9099 100644 --- a/requirements.txt +++ b/requirements.txt @@ -17 +17 @@ enum34;python_version=='2.7' or python_version=='2.6' -futurist>=0.1.1 # Apache-2.0 +futurist>=0.1.2 # Apache-2.0 diff --git a/test-requirements.txt b/test-requirements.txt index b0ed54c..5a06c57 100644 --- a/test-requirements.txt +++ b/test-requirements.txt @@ -7,2 +7 @@ oslotest>=1.7.0 # Apache-2.0 -mock!=1.1.4,>=1.1;python_version!='2.6' -mock==1.0.1;python_version=='2.6' +mock>=1.2