log = logging.getLogger("pbs.builds")
class Builds(base.Object):
- def _get_build(self, query, *args):
- res = self.db.get(query, *args)
-
- if res:
- return Build(self.backend, res.id, data=res)
-
- def _get_builds(self, query, *args):
- res = self.db.query(query, *args)
+ def _get_build(self, query, *args, **kwargs):
+ return self.db.fetch_one(Build, query, *args, **kwargs)
- for row in res:
- yield Build(self.backend, row.id, data=row)
+ def _get_builds(self, query, *args, **kwargs):
+ return self.db.fetch_many(Build, query, *args, **kwargs)
def __len__(self):
res = self.db.get("""
group,
test,
disable_test_builds,
+
+ # Populate cache
+ package=package, group=group, owner=owner, repo=repo,
)
- # Populate cache
+ # Update group cache
if group:
- build.group = group
group.builds.append(build)
# Create all jobs