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