

def commit(self):
    for notification in self.pending_notifications:
        logger.info(("Publishing '%s' to '%s' with routing_key '%s'" % (notification['event_type'], self.exchange, self.queue_name)))
        try:
            driver.send_notification(notification, self.queue_name, self.connection, self.exchange)
        except Exception as e:
            logger.exception(e)

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