Open Stack

We are amped to announce the release of:

taskflow 1.32.0: Taskflow structured state management library.

This release is part of the newton release series.

With source available at:

    http://git.openstack.org/cgit/openstack/taskflow

With package available at:

    https://pypi.python.org/pypi/taskflow

Please report issues through launchpad:

    http://bugs.launchpad.net/taskflow/

For more details, please see below.

Changes in taskflow 1.31.0..1.32.0
----------------------------------

f4eac0f Attempt to cancel active futures when suspending is underway
2618266 Allow for specifying green threaded to parallel engine
d1db445 Make conductor.stop stop the running engine gracefully
ddf58ff Add the ability to skip resolving from activating
67b9e41 Add periodic jobboard refreshing (incase of sync issues)
e8d78e7 Allow for revert to have a different argument list from execute
1489638 Use a automaton machine for WBE request state machine
b033fa6 Allow cachedproperty to avoid locking
3e3efc5 Spice up WBE banner and add simple worker __main__ entrypoint
97fd666 Add some basic/initial engine statistics
6957eec Ensure that the engine finishes up even under sent-in failures
7f84bf6 99 bottles example trace logging was not being output
131eb0c Replace clear zookeeper python with clear zookeeper bash
f774ec8 Add rundimentary and/or non-optimized job priorities
a8d9ae7 Have the storage class provide a 'change_flow_state' method

Diffstat (except docs and test files)
-------------------------------------

taskflow/atom.py                                  |  62 ++++++++---
taskflow/conductors/backends/impl_executor.py     |  42 +++++++-
taskflow/engines/action_engine/actions/retry.py   |  21 ++--
taskflow/engines/action_engine/actions/task.py    |   4 +-
taskflow/engines/action_engine/builder.py         | 119 +++++++++++++++-----
taskflow/engines/action_engine/completer.py       |  26 +++--
taskflow/engines/action_engine/engine.py          |  75 ++++++++++---
taskflow/engines/action_engine/executor.py        |  18 ++++
taskflow/engines/base.py                          |  16 +++
taskflow/engines/worker_based/executor.py         |   2 +-
taskflow/engines/worker_based/protocol.py         | 126 +++++++++++++++-------
taskflow/engines/worker_based/worker.py           | 120 +++++++++------------
taskflow/examples/99_bottles.py                   |   6 +-
taskflow/examples/alphabet_soup.py                |   2 +-
taskflow/examples/hello_world.py                  |  30 +++---
taskflow/jobs/backends/impl_redis.py              |  77 ++++++++-----
taskflow/jobs/backends/impl_zookeeper.py          |  82 +++++++++-----
taskflow/jobs/base.py                             | 120 +++++++++++++++++----
taskflow/storage.py                               |  15 +++
taskflow/task.py                                  |  19 +++-
taskflow/utils/banner.py                          | 107 ++++++++++++++++++
taskflow/utils/misc.py                            |  33 +++---
tools/clear_zk.py                                 |  50 ---------
tools/clear_zk.sh                                 |  15 +++
35 files changed, 1010 insertions(+), 351 deletions(-)