morpheus.stages.preprocess.deserialize_stage

DeserializeStage(c)

Messages are logically partitioned based on the specified c.pipeline_batch_size.