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(-)