watcher.applier.workflow_engine.default
Module¶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
watcher.applier.workflow_engine.default.
TaskFlowActionContainer
(db_action, engine)[source]¶Bases: watcher.applier.workflow_engine.base.BaseTaskFlowActionContainer
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]¶Activate a given atom which will perform some operation and return.
This method can be used to perform an action on a given set of input
requirements (passed in via *args
and **kwargs
) to accomplish
some type of operation. This operation may provide some named
outputs/results as a result of it executing for later reverting (or for
other atoms to depend on).
NOTE(harlowja): the result (if any) that is returned should be persistable so that it can be passed back into this atom if reverting is triggered (especially in the case where reverting happens in a different python process or on a remote machine) and so that the result can be transmitted to other atoms (which may be local or remote).
Parameters: |
|
---|
Except where otherwise noted, this document is licensed under Creative Commons Attribution 3.0 License. See all OpenStack Legal Documents.