seq  4.0.0-pre3
Public Member Functions | Static Public Attributes | List of all members
lib.seqtask.SeqTask Class Reference

Executes the nodes, first its dependencies. More...

Inheritance diagram for lib.seqtask.SeqTask:
lib.seqtask.LoopTask lib.seqtask.RTask

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)
 

Detailed Description

Executes the nodes, first its dependencies.

Later the nodes themselves.

For Action, Sequence and Parallel nodes.

Member Function Documentation

◆ __attrs_post_init__()

def lib.seqtask.SeqTask.__attrs_post_init__ (   self)

Inputs as dictionary, key by id.

Reimplemented in lib.seqtask.RTask, and lib.seqtask.LoopTask.

◆ abort()

def lib.seqtask.SeqTask.abort (   self)

Aborts the asyncio task.

◆ get_nodes()

def lib.seqtask.SeqTask.get_nodes (   self,
  l 
)

Get nodes from list od ids.

◆ get_task()

def lib.seqtask.SeqTask.get_task (   self)

Get my task object.

Creates it if not existing yet.

◆ input_task_list()

def lib.seqtask.SeqTask.input_task_list (   self)

Get input tasks that are not finished.

◆ reset()

def lib.seqtask.SeqTask.reset (   self,
  resume = False 
)

Creates a new task.

◆ resume_context()

def lib.seqtask.SeqTask.resume_context (   self)

context to make sure the resume flag is set to False at the end

◆ run()

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.

Member Data Documentation

◆ id

lib.seqtask.SeqTask.id = attr.ib()
static

◆ inputs

lib.seqtask.SeqTask.inputs = attr.ib(default=attr.Factory(list), repr=False)
static

◆ node

lib.seqtask.SeqTask.node = attr.ib(repr=False)
static

◆ resume

lib.seqtask.SeqTask.resume = attr.ib(default=False, repr=False)
static

The documentation for this class was generated from the following file: