'Sets the pipeline and context used for partial processing.
The pipeline should be a list of components that are previous to this one in the pipeline and
have already finished their training (and can therefore be safely used to process messages).'

def prepare_partial_processing(self, pipeline, context):

    self.partial_processing_pipeline = pipeline
    self.partial_processing_context = context
