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