Open Stack

We are satisfied to announce the release of:

taskflow 1.15.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.15.0

Please report issues through launchpad:

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

Changes in taskflow 1.14.0..1.15.0
----------------------------------

9478226 Provide a deprecated alias for the now removed stop watch class
9633c5b Update all removal_version from being ? to being 2.0
b03d524 Add deprecated and only alias modules for the moved types
e34dde2 Updated from global requirements
d4b153d Update the version on the old/deprecated logbook module
b8d2a5f Fix mock calls
27272a2 Integrate futurist (and **remove** taskflow originating code)
2eb1af3 Allow the 99_bottles.py demo to run in BLATHER mode
fcd005f Add more useful `__str__` to redis job
c5c2d84 Show job posted and goodbye in 99_bottles.py example
1e3dc09 Rename logbook module -> models module
63c6730 Notify on the individual engine steps
2b827e1 Add support for conditional execution
934b2bc Build-out + test a redis backed jobboard
4d0200f Add smarter/better/faster impl. of `ensure_atoms`
b7bb295 Add bulk `ensure_atoms` method to storage
9604703 Make it possible to see the queries executed (in BLATHER mode)
40d19c7 Handle conductor ctrl-c more appropriately

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

requirements.txt                                   |   3 +
setup.cfg                                          |   1 +
taskflow/conductors/backends/impl_blocking.py      |  34 +-
taskflow/conductors/base.py                        |  13 +
taskflow/conductors/single_threaded.py             |   2 +-
taskflow/engines/action_engine/actions/retry.py    |   5 +-
taskflow/engines/action_engine/analyzer.py         | 160 +++-
taskflow/engines/action_engine/engine.py           |   5 +-
taskflow/engines/action_engine/executor.py         |  13 +-
taskflow/engines/action_engine/runner.py           |  28 +-
taskflow/engines/action_engine/runtime.py          |  20 +
taskflow/engines/base.py                           |   4 +-
taskflow/engines/helpers.py                        |   2 +-
taskflow/engines/worker_based/executor.py          |   4 +-
taskflow/engines/worker_based/protocol.py          |   7 +-
taskflow/engines/worker_based/server.py            |   4 +-
taskflow/engines/worker_based/types.py             |   8 +-
taskflow/engines/worker_based/worker.py            |   4 +-
taskflow/examples/99_bottles.py                    | 113 ++-
taskflow/examples/hello_world.py                   |   9 +-
taskflow/examples/parallel_table_multiply.py       |   6 +-
taskflow/examples/persistence_example.py           |   4 +-
taskflow/examples/resume_vm_boot.py                |   4 +-
taskflow/examples/share_engine_thread.py           |   4 +-
taskflow/examples/switch_graph_flow.py             |  75 ++
taskflow/examples/tox_conductor.py                 |   8 +-
taskflow/flow.py                                   |   3 +
taskflow/jobs/backends/impl_redis.py               | 957 +++++++++++++++++++++
taskflow/jobs/backends/impl_zookeeper.py           | 195 ++---
taskflow/jobs/base.py                              |  89 +-
taskflow/listeners/base.py                         |   4 +-
taskflow/listeners/timing.py                       |   8 +-
taskflow/patterns/graph_flow.py                    |  18 +-
taskflow/persistence/backends/impl_memory.py       |   2 +-
taskflow/persistence/backends/impl_sqlalchemy.py   |  23 +-
.../versions/84d6e888850_add_task_detail_type.py   |   4 +-
taskflow/persistence/backends/sqlalchemy/tables.py |   4 +-
taskflow/persistence/base.py                       |   4 +-
taskflow/persistence/logbook.py                    | 889 +------------------
taskflow/persistence/models.py                     | 892 +++++++++++++++++++
taskflow/persistence/path_based.py                 |  28 +-
taskflow/states.py                                 |   5 +-
taskflow/storage.py                                | 144 ++--
taskflow/types/futures.py                          | 442 +---------
taskflow/types/latch.py                            |   4 +-
taskflow/types/periodic.py                         | 199 +----
taskflow/types/timing.py                           |   8 +-
taskflow/utils/async_utils.py                      |   9 +-
taskflow/utils/misc.py                             |  53 +-
taskflow/utils/persistence_utils.py                |  10 +-
taskflow/utils/redis_utils.py                      | 133 +++
taskflow/utils/threading_utils.py                  |  12 -
test-requirements.txt                              |   6 +-
tools/speed_test.py                                |   4 +-
tools/state_graph.py                               |  12 +-
85 files changed, 3310 insertions(+), 2487 deletions(-)


Requirements updates
--------------------

diff --git a/requirements.txt b/requirements.txt
index d4abcdd..24414c6 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -15,0 +16,3 @@ enum34;python_version=='2.7' or python_version=='2.6'
+# For async and/or periodic work
+futurist>=0.1.1 # Apache-2.0
+
diff --git a/test-requirements.txt b/test-requirements.txt
index 275836d..028c953 100644
--- a/test-requirements.txt
+++ b/test-requirements.txt
@@ -7 +7,2 @@ oslotest>=1.5.1 # Apache-2.0
-mock>=1.0
+mock>=1.1;python_version!='2.6'
+mock==1.0.1;python_version=='2.6'
@@ -17,0 +19,3 @@ kazoo>=2.2
+# Used for testing redis jobboards
+redis>=2.10.0
+