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