Open Stack

We eagerly announce the release of:

mistral 5.2.0: Mistral Project

This release is part of the pike release series.

Download the package from:

    https://pypi.python.org/pypi/mistral

For more details, please see below.

Changes in mistral 5.1.0..5.2.0
-------------------------------

b7d133d Add a periodic job to check workflow execution integrity
dbad9d3 Fix sporadically overwriting of finished workflow execution state
a77a3e7 Add retries to read-only db operations
57b92c5 'all' parameter breaks task context
2771a40 Re-raise DB errors when evaluating expressions
fd979d9 Add a config option to disable cron triggers
024e053 Remove wrapping of database exceptions in _get_collection()
afe641c Fix named locks implementation
34ab7a5 Replace or_ with in_ function for searching queries
75baddd Invoke AuthHook before ContextHook
b5f45ba Fix deletion of delayed calls
6ea1365 Add root_execution_id to sub-workflow executions
25951d3 Optimize mistral queries for 'get_task_executions'
f9129b7 Make scheduler delay configurable
556fbc4 Optimize sending result to parent workflow
27d4b4d Dynamic workflow name evaluation.
902b38d Removed NOT IN query from expiration policy.
359d0cd Allow mistral actions to run when authentication is not configured.
db997ee Mistral fails on RabbitMQ restart
943a0ad Process input defaults and output transforms for nested AdHoc Actions
d1a917e Replace @loopingcall.RetryDecorator with @tenacity.retry
aeba4ea Use @db_utils.retry_on_deadlock to retry scheduler transactions
9e3b36b Fix services launcher to handle shutdown properly
8364c3b Handle case with None encoding during std.http action execution
7c9c745 Fix "with-items" locking
ec12277 Fix Kombu RPC threading and use within multiprocess environment


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

mistral/actions/openstack/actions.py               |  15 +-
mistral/actions/std_actions.py                     |   2 +-
mistral/api/app.py                                 |   6 +-
mistral/api/controllers/v2/action.py               |   4 +-
mistral/api/controllers/v2/action_execution.py     |   8 +
mistral/api/controllers/v2/cron_trigger.py         |   4 +-
mistral/api/controllers/v2/environment.py          |   4 +-
mistral/api/controllers/v2/event_trigger.py        |   4 +-
mistral/api/controllers/v2/execution.py            |  28 ++-
mistral/api/controllers/v2/member.py               |   5 +-
mistral/api/controllers/v2/task.py                 |  20 +-
mistral/api/controllers/v2/workbook.py             |   4 +-
mistral/api/controllers/v2/workflow.py             |   5 +-
mistral/api/service.py                             |  12 ++
mistral/cmd/launch.py                              |  79 +++++---
mistral/config.py                                  |  63 ++++++-
.../versions/023_add_root_execution_id.py          |  36 ++++
...d_composite_index_workflow_execution_id_name.py |  34 ++++
mistral/db/utils.py                                |  27 +--
mistral/db/v2/api.py                               |  22 ++-
mistral/db/v2/sqlalchemy/api.py                    | 159 ++++++++++------
mistral/db/v2/sqlalchemy/models.py                 |  13 ++
mistral/engine/action_handler.py                   |   3 +-
mistral/engine/action_queue.py                     |  69 +++++--
mistral/engine/actions.py                          |  51 ++++--
mistral/engine/default_engine.py                   |   8 +
mistral/engine/engine_server.py                    |   2 +-
mistral/engine/policies.py                         |   4 +
mistral/engine/task_handler.py                     |   4 +
mistral/engine/tasks.py                            | 176 ++++++++++--------
mistral/engine/workflow_handler.py                 |  76 +++++++-
mistral/engine/workflows.py                        | 105 +++++------
mistral/exceptions.py                              |   4 -
mistral/executors/remote_executor.py               |   4 +-
mistral/expressions/jinja_expression.py            |  21 +++
mistral/expressions/yaql_expression.py             |  19 ++
mistral/lang/base.py                               |  12 +-
mistral/lang/v2/tasks.py                           |   7 +-
mistral/rpc/clients.py                             |  31 +++-
mistral/rpc/kombu/base.py                          |   5 +-
mistral/rpc/kombu/kombu_client.py                  |  72 ++++++--
mistral/rpc/kombu/kombu_listener.py                |  25 ++-
mistral/rpc/kombu/kombu_server.py                  |  41 ++++-
mistral/services/expiration_policy.py              |  24 ++-
mistral/services/periodic.py                       |  11 +-
mistral/services/scheduler.py                      | 204 +++++++++++++++------
mistral/services/triggers.py                       |   3 +
.../actions/openstack/test_openstack_actions.py    |  31 ++++
.../unit/engine/test_subworkflows_pause_resume.py  |  33 ++--
mistral/utils/rest_utils.py                        |  54 ++++--
mistral/workflow/lookup_utils.py                   |   3 +-
79 files changed, 2442 insertions(+), 707 deletions(-)