morpheus.pipeline.control_message_stage#

Classes

ControlMessageStage(c)

Subclass of SinglePortStage with option to log timestamps in MessageMeta dataframe.