self.upgradeSchema = function(callback) {
        var query = "SELECT * FROM pgq.upgrade_schema()";
        self.db.query.first(query, [], callback);
    };