'Send a metering message for publishing
:param samples: Samples from pipeline after transformation'

def publish_samples(self, samples):

    if self.publisher_logger:
        for sample in samples:
            self.publisher_logger.info(sample.as_dict())
