|
def | __attrs_post_init__ (self) |
| Assigns node's name and id. More...
|
|
def | set_params (self, d) |
|
def | execute (self, resume=False) |
|
def | __iter__ (self) |
|
def | context (self) |
| Get context dictionary, preferably from root node. More...
|
|
def | context (self, ctx) |
|
def | seq (self) |
| Retrieves the sequence list. More...
|
|
def | seq (self, s) |
| List used to create the Sequence's graph. More...
|
|
def | G (self) |
| returns the graph object More...
|
|
def | start_step (self) |
|
def | end_step (self) |
|
def | start_node (self) |
| Returns the start node. More...
|
|
def | end_node (self) |
| Returns the end node. More...
|
|
def | append (self, s) |
| Appends a node to the Sequence. More...
|
|
def | make_sequence (self) |
| 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) |
|
def | resume (self) |
|
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 | state (self) |
| Gets the node state. More...
|
|
def | state (self, value) |
| Sets the node state. More...
|
|
def | publish_state (self) |
|
def | state (self, value) |
| Sets the node state. More...
|
|
def | result (self) |
| Node's result. More...
|
|
def | result (self, val) |
|
def | full_state (self) |
| Gets the node state. More...
|
|
def | in_error (self) |
|
def | skip (self) |
|
def | skip (self, flag=True) |
|
def | in_error (self, flag=True) |
|
def | make_task (self, node, input_list, resume) |
| Creates the task object that executes the node. More...
|
|
def | pause (self) |
|
|
| tpl_name = attr.ib(default=None) |
|
| params = attr.ib(default=attr.Factory(list), repr=False) |
|
| content = attr.ib(default=attr.Factory(dict), repr=False) |
|
| mod = attr.ib(default=None, repr=False, init=False) |
|
| P = cv.ContextVar("P", default={}) |
|
| graph = attr.ib(init=False, default=attr.Factory(nx.DiGraph), repr=False) |
|
| debug = attr.ib(init=False, default=False, repr=False) |
|
| current_tpl = cv.ContextVar("current_tpl", default=None) |
|
| root = cv.ContextVar("root", default=None) |
|
| serial_number = attr.ib(default=0, kw_only=True) |
|
| id = attr.ib(default=None, kw_only=True) |
|
| name = attr.ib(default=None, kw_only=True) |
|
| runtime_flags = attr.ib(default=0, init=False) |
|
| 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 |
|