seq
4.0.0-pre3
|
Executes the nodes, first its dependencies. More...
Public Member Functions | |
def | __attrs_post_init__ (self) |
Inputs as dictionary, key by id. More... | |
def | input_task_list (self) |
Get input tasks that are not finished. More... | |
def | get_nodes (self, l) |
Get nodes from list od ids. More... | |
def | run (self) |
Simple run method. More... | |
def | get_task (self) |
Get my task object. More... | |
def | abort (self) |
Aborts the asyncio task. More... | |
def | reset (self, resume=False) |
Creates a new task. More... | |
def | resume_context (self) |
context to make sure the resume flag is set to False at the end More... | |
Static Public Attributes | |
id = attr.ib() | |
node = attr.ib(repr=False) | |
inputs = attr.ib(default=attr.Factory(list), repr=False) | |
resume = attr.ib(default=False, repr=False) | |
Executes the nodes, first its dependencies.
Later the nodes themselves.
For Action, Sequence and Parallel nodes.
def lib.seqtask.SeqTask.__attrs_post_init__ | ( | self | ) |
Inputs as dictionary, key by id.
Reimplemented in lib.seqtask.RTask, and lib.seqtask.LoopTask.
def lib.seqtask.SeqTask.abort | ( | self | ) |
Aborts the asyncio task.
def lib.seqtask.SeqTask.get_nodes | ( | self, | |
l | |||
) |
Get nodes from list od ids.
def lib.seqtask.SeqTask.get_task | ( | self | ) |
Get my task object.
Creates it if not existing yet.
def lib.seqtask.SeqTask.input_task_list | ( | self | ) |
Get input tasks that are not finished.
def lib.seqtask.SeqTask.reset | ( | self, | |
resume = False |
|||
) |
Creates a new task.
def lib.seqtask.SeqTask.resume_context | ( | self | ) |
context to make sure the resume flag is set to False at the end
def lib.seqtask.SeqTask.run | ( | self | ) |
Simple run method.
Awaits inputs, then schedules execution of its own node (either a function or template).
Reimplemented in lib.seqtask.RTask, and lib.seqtask.LoopTask.
|
static |
|
static |
|
static |
|
static |