from mistral.actions import base class RunnerAction(base.Action): def __init__(self, param): # store the incoming params self.param = param def run(self): # return your results here return {'status': 0}
[entry_points] mistral.actions = example.runner = my.mistral_plugins.somefile:RunnerAction
$ tools/sync_db.sh --config-file <path-to-config>
or
$ mistral-db-manage --config-file <path-to-config> populate
my_workflow: tasks: my_action_task: action: example.runner input: param: avalue_to_pass_in