

def commit(self):
    for event in self.events:
        event_type = event.get('event_type', '')
        message_id = event.get('message_id', '')
        try:
            status = self.publish_event(event)
            logger.debug(('Sent %s event %s. Status %s' % (event_type, message_id, status)))
        except Exception:
            original_message_id = event.get('original_message_id', '')
            logger.exception(('Error publishing %s event %s (original id: %s)!' % (event_type, message_id, original_message_id)))

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