selinon.run module

Selinon flow scheduling (entrypoint) for a user.

selinon.run.run_flow(flow_name, node_args=None)[source]

Run flow by it’s name.

Parameters:
  • flow_name – name of the flow to be run
  • node_args – arguments that will be supplied to flow
Returns:

flow ID (dispatcher ID)

selinon.run.run_flow_selective(flow_name, task_names, node_args, follow_subflows=False, run_subsequent=False)[source]

Run only desired tasks in a flow.

Parameters:
  • flow_name – name of the flow that should be run
  • task_names – name of the tasks that should be run
  • node_args – arguments that should be supplied to flow
  • follow_subflows – if True, subflows will be followed and checked for nodes to be run
  • run_subsequent – trigger run of all tasks that depend on the desired task
Returns:

dispatcher id that is scheduled to run desired selective task flow

Raises:

selinon.errors.SelectiveNoPathError – there was no way found to the desired task in the flow