X-Git-Url: https://git.decadent.org.uk/gitweb/?a=blobdiff_plain;f=daklib%2Fbinary.py;h=92727951cb63a5f93b84af238ee740635a769304;hb=fcb5dd60b62794747cf976feadf9208b98de7bd8;hp=5deb4a5c0b3cb2ff4761117d3515eda06ea2bcb5;hpb=513d05b0a10846e79cba8ee93deecc68e65cdae1;p=dak.git diff --git a/daklib/binary.py b/daklib/binary.py index 5deb4a5c..92727951 100755 --- a/daklib/binary.py +++ b/daklib/binary.py @@ -53,6 +53,12 @@ from dbconn import * from config import Config import utils +################################################################################ + +__all__ = [] + +################################################################################ + class Binary(object): def __init__(self, filename, reject=None): """ @@ -66,6 +72,8 @@ class Binary(object): self.tmpdir = None self.chunks = None self.wrapped_reject = reject + # Store rejects for later use + self.rejects = [] def reject(self, message): """ @@ -73,6 +81,7 @@ class Binary(object): otherwise send it to stderr. """ print >> sys.stderr, message + self.rejects.append(message) if self.wrapped_reject: self.wrapped_reject(message) @@ -300,6 +309,7 @@ def copy_temporary_contents(package, version, archname, deb, reject, session=Non sql = """DELETE from pending_content_associations WHERE package=:package AND version=:version AND architecture=:archid""" session.execute(sql, vals) + session.commit() return exists