

def publish_event(self, event):
    (content, content_type) = self.format(event)
    event_type = self.get_event_type(event.get('event_type'))
    atom = self.generate_atom(event, event_type, content, content_type, title=self.title, categories=self.categories)
    logger.debug(('Publishing event: %s' % atom))
    return self._send_event(atom)

dataset/ETHPy150Open openstack/stacktach-winchester/winchester/pipeline_handler.py AtomPubHandler.publish_event/original