|
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.