morpheus.pipeline.receiver.Receiver

class Receiver(parent, port_number)[source]

Bases: object

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

Parameters
parentmorpheus.pipeline.pipeline.StageBase

Parent StageBase object.

port_numberint

Receiver port number.

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.

The node linking phase connects all underlying stages.

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.

Previous morpheus.pipeline.receiver
Next morpheus.pipeline.sender
© Copyright 2023, NVIDIA. Last updated on Feb 2, 2024.