self.reinsertRetryEvents = function(callback) {
        var query = 'SELECT * FROM pgq.maint_retry_events()';
        self.db.query.first(query, [], callback);
    };