artemis.core.steering

Steering executes business processes as a computation graph

Module Contents

class artemis.core.steering.Steering(name, **kwargs)

Bases: artemis.core.algo.AlgoBase

Steering manages algorithm execution of a business process graph.

_menu

Sorted graph of algorithm names

Type

OrderedDict

_algo_instances

Configured algorithm objects

Type

Dict

_chunk_cntr

counter for number of

Type

int

Parameters

name (str) – Configured name of algorithm

Examples

initialize(self)

initialize method calls from_msg

from_msg(self)

Configure steering from a protobuf msg.

lock(self)

Overides the base class lock. Controls locking of all algorithm properties

book(self)

book method calls book on all algorithms in the menu

rebook(self)

retrieve the sampling times and rebook

_element_name(self, key)

retrieve datastore element name with key.

execute(self, payload)

Prepares payload for algorithms and controls the algorithm execution.

Parameters

payload (pyarrow.buffer) – Expected that payload is a pyarrow buffer.

Raises

Exception –

finalize(self)

finalize method calls finalize on all algorithms in menu