seq
2.0.0
|
Public Member Functions | |
def | __attrs_post_init__ (self) |
def | context (self) |
Get context from the running Sequence. More... | |
def | publish_state (self) |
Requests controller object to publish node's state. More... | |
def | state (self) |
Gets the node state. More... | |
def | state (self, value) |
Sets the node state. More... | |
def | __call__ (self, resume=False) |
![]() | |
def | result (self) |
Node's result. More... | |
def | result (self, val) |
def | end_node (self) |
def | start_node (self) |
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_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) |
def | resume (self) |
Public Attributes | |
name | |
id | |
serial_number | |
description | |
state | |
logger.info("PREAMBLE ...: %s -- %d", self.name, self.runtime_flags) More... | |
t_start | |
skip | |
t_end | |
result | |
in_error | |
exception | |
Static Public Attributes | |
f = attr.ib(default=None, repr=False) | |
![]() | |
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 | |
Action ctor.
Action nodes executes coroutines
in a Sequencer script.
f | The coroutine the node will execute |
id | Unique id. If not provided an unique identifier is assigned. |
name | Node name. If not provided a name is assigned. |
TypeException | is f is not a coroutine. |
def lib.nodes.action.Action.__attrs_post_init__ | ( | self | ) |
def lib.nodes.action.Action.__call__ | ( | self, | |
resume = False |
|||
) |
Executes node action. If the action is a coroutine a task is created and passed to the asyncio loop for execution.
Reimplemented in lib.nodes.action.ActionInThread.
def lib.nodes.action.Action.context | ( | self | ) |
Get context from the running Sequence.
def lib.nodes.action.Action.publish_state | ( | self | ) |
Requests controller object to publish node's state.
def lib.nodes.action.Action.state | ( | self | ) |
Gets the node state.
Reimplemented from lib.nodes.interface._BaseNode.
def lib.nodes.action.Action.state | ( | self, | |
value | |||
) |
Sets the node state.
Reimplemented from lib.nodes.interface._BaseNode.
lib.nodes.action.Action.description |
lib.nodes.action.Action.exception |
|
static |
lib.nodes.action.Action.id |
lib.nodes.action.Action.in_error |
lib.nodes.action.Action.name |
lib.nodes.action.Action.result |
lib.nodes.action.Action.serial_number |
lib.nodes.action.Action.skip |
lib.nodes.action.Action.state |
logger.info("PREAMBLE ...: %s -- %d", self.name, self.runtime_flags)
lib.nodes.action.Action.t_end |
lib.nodes.action.Action.t_start |