'Send an event message for publishing
:param events: events from pipeline after transformation'

def publish_events(self, events):

    if self.publisher_logger:
        for event in events:
            self.publisher_logger.info(event.as_dict())
