From db53d2fdcf575fc4633edc93cb5112125d4de78f Mon Sep 17 00:00:00 2001 From: Jocelyn Jaubert Date: Mon, 27 Feb 2012 11:09:02 +0100 Subject: [PATCH 1/2] Add optional branch argument to function getRecentChanges() --- master/buildbot/db/changes.py | 11 ++++++++++- 1 files changed, 10 insertions(+), 1 deletions(-) diff --git a/master/buildbot/db/changes.py b/master/buildbot/db/changes.py index 050babe..85acd58 100644 --- a/master/buildbot/db/changes.py +++ b/master/buildbot/db/changes.py @@ -137,12 +137,21 @@ class ChangesConnectorComponent(base.DBConnectorComponent): d = self.db.pool.do(thd) return d - def getRecentChanges(self, count): + def getRecentChanges(self, count, branch=None): def thd(conn): # get the changeids from the 'changes' table changes_tbl = self.db.model.changes + if branch != None: + if branch == '': + where_opt = (changes_tbl.c.branch == None) + else: + where_opt = (changes_tbl.c.branch == branch) + else: + where_opt = None + q = sa.select([changes_tbl.c.changeid], order_by=[sa.desc(changes_tbl.c.changeid)], + whereclause=where_opt, limit=count) rp = conn.execute(q) changeids = [ row.changeid for row in rp ] -- 1.7.4.2