morpheus.pipeline.receiver.Receiver#

class Receiver(parent, port_number)[source]#

The Receiver object represents a downstream port on a StageBase object that gets messages from a Sender.

Parameters:

Attributes:

input_schema
input_type: Returns the the upstream node’s output type, and in case of multiple upstreams this will return the common ancestor type.
is_complete: A receiver is complete if all input senders are also complete.
is_partial: A receiver is partially complete if any input sender is complete.
parent

Methods

`get_input_node`(builder)	Returns the input or parent node.
`link_node`(builder)	The node linking phase connects all underlying stages.
`link_schema`()	The type linking phase determines the final type of the `Receiver`.

get_input_schema

get_input_node(builder)[source]#

Returns the input or parent node.

property input_type: type#: Returns the the upstream node’s output type, and in case of multiple upstreams this will return the common ancestor type.

property is_complete#: A receiver is complete if all input senders are also complete.

property is_partial#: A receiver is partially complete if any input sender is complete. Receivers are usually partially complete if there is a circular pipeline.

link_node(builder)[source]#

The node linking phase connects all underlying stages.

link_schema()[source]#

The type linking phase determines the final type of the Receiver.

Raises:: RuntimeError: Throws a RuntimeError if the predicted input port type determined during the build phase is different than the current port type.