lib.nodes.recover.RLoop Class Reference

My RLoop Class. More...

Inheritance diagram for lib.nodes.recover.RLoop:

Public Member Functions
def	__attrs_post_init__ (self)
	Assigns node's name and id. More...
def	make_task (self, node, input_list, resume)
	Creates the task object that executes the node. More...
Public Member Functions inherited from lib.nodes.loop.Loop
def	end_step (self)
def	make_sequence (self)
	Creates the Loop execution graph. More...
def	set_block (self, *args)
	Assigns the sequence to the loop's block. More...
def	nodes (self)
	Return nodes from Graph. More...
def	get_node (self, node_id)
	Get node by id. More...
Public Member Functions inherited from lib.nodes.sequence.Sequence
def	__iter__ (self)
def	context (self)
	Get context dictionary, preferably from root node. More...
def	context (self, ctx)
def	seq (self)
	Retrieves the sequence list. More...
def	seq (self, s)
	List used to create the Sequence's graph. More...
def	G (self)
	returns the graph object More...
def	start_step (self)
def	start_node (self)
	Returns the start node. More...
def	end_node (self)
	Returns the end node. More...
def	append (self, s)
	Appends a node to the Sequence. More...
def	create_node_tasks (self, resume=False)
	Creates Task object associated to this node. More...
def	reschedule_node (self, node_id)
	Reschedule a node for execution. More...
def	start (self, make_sequence=True, resume=False)
	This is the entry point for Sequence execution. More...
def	run (self)
def	execute (self, resume=False)
def	resume (self)
def	main_task (self)
	Returns the objective node of the sequence – the end node. More...
def	__call__ (self, resume=False)
def	abort (self)
	Aborts the sequence. More...
def	get_task (self, node_id)
	Get task by node_id. More...
def	state (self)
	Gets the node state. More...
def	state (self, value)
	Sets the node state. More...
def	publish_state (self)
def	state (self, value)
	Sets the node state. More...
Public Member Functions inherited from lib.nodes.interface._BaseNode
def	result (self)
	Node's result. More...
def	result (self, val)
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	pause (self)

Static Public Member Functions
def	create (source, *args, **kw)
Static Public Member Functions inherited from lib.nodes.loop.Loop
def	create (*args, **kw)
	Creates a :class:Loop node. More...
Static Public Member Functions inherited from lib.nodes.sequence.Sequence
def	get_context ()

Public Attributes
	name
Public Attributes inherited from lib.nodes.loop.Loop
	name
	state
	in_error
Public Attributes inherited from lib.nodes.sequence.Sequence
	name
	id
	serial_number
	state
	node state More...
	in_error
	runtime_flags
	t_start
	skip
	exception
	t_end

Static Public Attributes
	max_retry = attr.ib(default=1, kw_only=True)
	err_tbl = attr.ib(default=dict(), kw_only=True, repr=False)
Static Public Attributes inherited from lib.nodes.loop.Loop
	block_args = attr.ib(kw_only=True, default=attr.Factory(list), repr=False)
	condition = attr.ib(kw_only=True, default=None, repr=False)
	init = attr.ib(kw_only=True, default=None, repr=False)
	block = attr.ib(init=False, default=None, repr=False)
	index = cv.ContextVar("index", default=0)
Static Public Attributes inherited from lib.nodes.sequence.Sequence
	graph = attr.ib(init=False, default=attr.Factory(nx.DiGraph), repr=False)
	debug = attr.ib(init=False, default=False, repr=False)
	current_tpl = cv.ContextVar("current_tpl", default=None)
	root = cv.ContextVar("root", default=None)
Static Public Attributes inherited from lib.nodes.interface._BaseNode
	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

Detailed Description

My RLoop Class.

    id (Optional str): Node id.
    name (Optional str): Node name.

Parameters

init	Initialization node.
condition	A Python method that returns a boolean value.

Member Function Documentation

__attrs_post_init__()

def lib.nodes.recover.RLoop.__attrs_post_init__

(

self

)

Assigns node's name and id.

Reimplemented from lib.nodes.loop.Loop.

create()

def lib.nodes.recover.RLoop.create (   source, *  args, **  kw  )

static

make_task()

def lib.nodes.recover.RLoop.make_task	(		self,
			node,
			input_list,
			resume
	)

Creates the task object that executes the node.

Reimplemented from lib.nodes.loop.Loop.

Member Data Documentation

err_tbl

lib.nodes.recover.RLoop.err_tbl = attr.ib(default=dict(), kw_only=True, repr=False)

static

max_retry

lib.nodes.recover.RLoop.max_retry = attr.ib(default=1, kw_only=True)

static

name

lib.nodes.recover.RLoop.name

---

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

• seq/seqlib/src/seq/lib/nodes/recover.py