selinon.system_state module

Main system actions done by Selinon.

class selinon.system_state.SystemState(dispatcher_id, flow_name, node_args=None, retry=None, state=None, parent=None, selective=None)[source]

Bases: object

Main system actions done by Selinon.

node_args

Node arguments.

Returns:arguments for a node
selective

All edges that should be started selectively as computed by compute_selective.

to_dict()[source]

Serialize current system state.

Returns:converted system state to dict
update()[source]

Check the current state in the system and start new nodes if possible.

Returns:retry count - can be None (do not retry dispatcher) or time in seconds to retry