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 +