lib.nodes.parallel.Parallel Class Reference

Parallel node definition. More...

Inheritance diagram for lib.nodes.parallel.Parallel:

Public Member Functions
def	__attrs_post_init__ (self)
	Assigns node's name and id. More...
def	__repr__ (self)
def	make_sequence (self, parent_tpl=None)
	Builds this sequence execution graph. More...
Public Member Functions inherited from lib.nodes.sequence.Sequence
def	__iter__ (self)
def	start_step (self)
	Standard sequence's start step. More...
def	end_step (self)
	Standard sequence's end step. 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)
	Runs the node – This executes the task. More...
def	execute (self, resume=False, propagate=False)
	Executes this just creates the asyncio task. More...
def	resume (self)
	Resume node execution. More...
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	nodes (self)
	Return nodes from Graph. More...
def	get_node (self, node_id)
	Get node by id. More...
def	get_task (self, node_id)
	Get task by node_id. More...
def	par (self, k)
	Get a parameter value. More...
def	set (self, p)
	Sets the value of a parameter. More...
Public Member Functions inherited from lib.nodes.interface._BaseNode
def	make_sequence (self)
	does nothing More...
def	make_task (self, node, input_list, resume)
	Creates the task object that executes the node. More...
def	pause (self)

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

Public Attributes
	name
	seq
	runtime_flags
Public Attributes inherited from lib.nodes.sequence.Sequence
	name
	id
	in_error
	runtime_flags
	t_start
	skip
	exception
	t_end

Static Public Attributes
	seq_args = attr.ib(kw_only=True, default=attr.Factory(list), repr=False)
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_seq = cv.ContextVar("current_seq", default=None)
	root = cv.ContextVar("root", default=None)
Static Public Attributes inherited from lib.nodes.interface._BaseNode
	id = attr.ib(default=None, kw_only=True)
	name = attr.ib(default=None, kw_only=True)
	runtime_flags = attr.ib(default=0, kw_only=True)
	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
	serial_number = attr.ib(init=False)

Additional Inherited Members
Properties inherited from lib.nodes.sequence.Sequence
	context = property
	Get context dictionary, preferably from root node. More...
	seq = property
	Retrieves the sequence list. More...
	G = property
	returns the graph object More...
	start_node = property
	Returns the start node. More...
	end_node = property
	Returns the end node. More...
	parameters = property
	Return parameters. More...
	state = property
	node state More...
	full_state = property
Properties inherited from lib.nodes.interface._BaseNode
	result = property
	Node's result. More...
	end_node = property
	start_node = property
	state = property
	Gets the node state. More...
	full_state = property
	Gets the node state. More...
	in_error = property
	skip = property

Detailed Description

Parallel node definition.

Use the :meth:create method to build properly :class:Parallel nodes. Since it inherits from :class:Sequence it has access to the same context variables.

Examples

One can access the running Sequence using Sequence.current_seq context variable.

>>> s = Parallel.create(a,b, name="my sequence")
# execute Sequence
>>> await s.start()
# Get running Sequence from Inside function a():
>>> def a():
...     current_seq = Sequence.current_seq
...     # now current_seq is the node s
...     assert current_seq == s

Member Function Documentation

__attrs_post_init__()

def lib.nodes.parallel.Parallel.__attrs_post_init__

(

self

)

Assigns node's name and id.

Reimplemented from lib.nodes.sequence.Sequence.

__repr__()

def lib.nodes.parallel.Parallel.__repr__

(

self

)

create()

def lib.nodes.parallel.Parallel.create ( *  args, **  kw  )

static

Creates a :class:Parallel node.

        *args: Variable length list of nodes or coroutines that compose the sequence.

Parameters

id	Node id
name	node name

Reimplemented from lib.nodes.sequence.Sequence.

make_sequence()

def lib.nodes.parallel.Parallel.make_sequence	(		self,
			parent_tpl = None
	)

Builds this sequence execution graph.

Joins the Sequence's nodes together.

Reimplemented from lib.nodes.sequence.Sequence.

Member Data Documentation

name

lib.nodes.parallel.Parallel.name

runtime_flags

lib.nodes.parallel.Parallel.runtime_flags

seq

lib.nodes.parallel.Parallel.seq

seq_args

lib.nodes.parallel.Parallel.seq_args = attr.ib(kw_only=True, default=attr.Factory(list), repr=False)

static

---

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

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