The watcher.applier.workflow_engine.default Module¶

class watcher.applier.workflow_engine.default.DefaultWorkFlowEngine(config, context=None, applier_manager=None)[source]¶

Bases: watcher.applier.workflow_engine.base.BaseWorkFlowEngine

Taskflow as a workflow engine for Watcher

Full documentation on taskflow at https://docs.openstack.org/taskflow/latest

decider(history)[source]¶

execute(actions)[source]¶

classmethod get_config_opts()[source]¶

class watcher.applier.workflow_engine.default.TaskFlowActionContainer(db_action, engine)[source]¶

Bases: watcher.applier.workflow_engine.base.BaseTaskFlowActionContainer

do_abort(*args, **kwargs)[source]¶

do_execute(*args, **kwargs)[source]¶

do_post_execute()[source]¶

do_pre_execute()[source]¶

do_revert(*args, **kwargs)[source]¶

class watcher.applier.workflow_engine.default.TaskFlowNop(name=None, provides=None, requires=None, auto_extract=True, rebind=None, inject=None, ignore_list=None, revert_rebind=None, revert_requires=None)[source]¶

Bases: taskflow.task.Task

This class is used in case of the workflow have only one Action.

We need at least two atoms to create a link.

execute()[source]¶