|
| def | __attrs_post_init__ (self) |
| | Assigns node's name and id. More...
|
| |
| def | load (self) |
| | Loads json file. More...
|
| |
| def | clone (self, *args, **kw) |
| | Fake ctor for OB nodes. More...
|
| |
| def | __iter__ (self) |
| |
| def | start_step (self) |
| | Standard sequence's start step. More...
|
| |
| def | end_step (self) |
| | Standard sequence's end step. More...
|
| |
| def | append (self, s) |
| | Appends a node to the Sequence. More...
|
| |
| def | make_sequence (self, parent_tpl=None) |
| | Builds this sequence execution graph. More...
|
| |
| def | create_node_tasks (self, resume=False) |
| | Creates Task object associated to this node. More...
|
| |
| def | reschedule_node (self, node_id) |
| | Reschedule a node for execution. More...
|
| |
| def | start (self, make_sequence=True, resume=False) |
| | This is the entry point for Sequence execution. More...
|
| |
| def | run (self) |
| | Runs the node – This executes the task. More...
|
| |
| def | execute (self, resume=False, propagate=False) |
| | Executes this just creates the asyncio task. More...
|
| |
| def | resume (self) |
| | Resume node execution. More...
|
| |
| def | main_task (self) |
| | Returns the objective node of the sequence – the end node. More...
|
| |
| def | __call__ (self, resume=False) |
| |
| def | abort (self) |
| | Aborts the sequence. More...
|
| |
| def | nodes (self) |
| | Return nodes from Graph. More...
|
| |
| def | get_node (self, node_id) |
| | Get node by id. More...
|
| |
| def | get_task (self, node_id) |
| | Get task by node_id. More...
|
| |
| def | par (self, k) |
| | Get a parameter value. More...
|
| |
| def | set (self, p) |
| | Sets the value of a parameter. More...
|
| |
| def | make_sequence (self) |
| | does nothing More...
|
| |
| def | make_task (self, node, input_list, resume) |
| | Creates the task object that executes the node. More...
|
| |
| def | pause (self) |
| |
|
| | fname = attr.ib(default=None) |
| |
| | content = attr.ib(default=attr.Factory(dict), repr=False, init=False) |
| |
| dictionary | template_parameters = {} |
| |
| | current_tpl_params = attr.ib(default=attr.Factory(dict), init=False) |
| |
| | ctor = attr.ib(default=None, init=False) |
| |
| | descr = attr.ib(default=attr.Factory(dict), init=False) |
| |
| | from_otto = attr.ib(default=False, kw_only=True) |
| |
| | graph = attr.ib(init=False, default=attr.Factory(nx.DiGraph), repr=False) |
| |
| | debug = attr.ib(init=False, default=False, repr=False) |
| |
| | current_seq = cv.ContextVar("current_seq", default=None) |
| |
| | root = cv.ContextVar("root", default=None) |
| |
| | id = attr.ib(default=None, kw_only=True) |
| |
| | name = attr.ib(default=None, kw_only=True) |
| |
| | runtime_flags = attr.ib(default=0, kw_only=True) |
| |
| | deps = attr.ib(default=attr.Factory(list), repr=False, kw_only=True, init=False) |
| |
| | description = attr.ib(default="", kw_only=True) |
| |
| | exception = attr.ib(init=False, default=None, repr=False) |
| |
| | can_skip = attr.ib(default=True, init=False) |
| |
| | hide = attr.ib(default=False, init=False) |
| |
| | t_start = attr.ib(init=False, default=None, repr=False) |
| |
| | t_end = attr.ib(init=False, default=None, repr=False) |
| |
| | running_checkpoint |
| |
| | serial_number = attr.ib(init=False) |
| |
Represents a Sequence from an OB file (json).
The JSON file contains a lot of data, however the Sequencer only cares about the templates section::
"templates": [
{
"templateName": "seq.samples.a",
"type": "string"
},
{
"templateName": "seq.samples.tpa",
"type": "string",
"parameters": [
{
"name": "par_b",
"type": "integer",
"value": 0
},
{
"name": "par_c",
"type": "number",
"value": 77
}
]
}
],
Inside the templates section there is list of templateName objects. The templateName defines a Python module that can be directly imported (it is reachable from PYTHONPATH).
Each template might contain a list of parameters that can be accessed from corresponding python code that implements the template.