morpheus.stages.preprocess.deserialize_stage

DeserializeStage(c[, ensure_sliceable_index])

Messages are logically partitioned based on the pipeline config's pipeline_batch_size parameter.