'Allows the component to process messages during training (e.g. external training data).
The passed message will be processed by all components previous to this one in the pipeline.'

def partially_process(self, message):

    if (self.partial_processing_context is not None):
        for component in self.partial_processing_pipeline:
            component.process(message, **self.partial_processing_context)
    else:
        logger.info(u'Failed    to    run    partial    processing    due    to    missing    pipeline.')
    return message
