in crashclouseau/models.py [0:0]
def to_analyze(chgsets=[], channel=""):
if not channel:
fl = (
db.session.query(Changeset.nodeid, Node.node, Node.channel)
.select_from(Changeset)
.join(Node)
)
fl = (
fl.filter(Node.merge.is_(False), Changeset.analyzed.is_(False))
.distinct(Node.id)
.first()
)
return (fl.nodeid, fl.node, fl.channel) if fl else (None, None, None)
if not chgsets:
return []
chgsets = list(chgsets)
fls = (
db.session.query(Changeset.id, Node.id, Node.node)
.select_from(Changeset)
.join(Node)
)
fls = fls.filter(
Node.node.in_(chgsets),
Node.channel == channel,
Node.merge.is_(False),
Changeset.analyzed.is_(False),
).distinct(Node.id)
res = [(nodeid, node) for _, nodeid, node in fls]
return res