Retry loop task. More...

Inheritance diagram for lib.seqtask.RTask:

Public Member Functions
def	__attrs_post_init__ (self)
	Inputs as dictionary, key by id. More...

def	run (self)

def	handle_exception (self)

Public Member Functions inherited from lib.seqtask.SeqTask
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	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
	block = attr.ib(init=False)

	err_tbl = attr.ib(init=False)

	condition = attr.ib(init=False)

Static Public Attributes inherited from lib.seqtask.SeqTask
	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

Retry loop task.

Member Function Documentation

def lib.seqtask.RTask.__attrs_post_init__ ( self )

Inputs as dictionary, key by id.

Reimplemented from lib.seqtask.SeqTask.

def lib.seqtask.RTask.handle_exception ( self )

Exception handler

def lib.seqtask.RTask.run ( self )

Simple run method.
Awaits inputs, then schedules execution of its own node (either a function
or template).

Reimplemented from lib.seqtask.SeqTask.

lib.seqtask.RTask.block = attr.ib(init=False)

static

lib.seqtask.RTask.condition = attr.ib(init=False)

static

lib.seqtask.RTask.err_tbl = attr.ib(init=False)

static

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