try:
return function(directory, upload, *args, **kwargs)
except (daklib.archive.ArchiveException, daklib.checks.Reject) as e:
try:
return function(directory, upload, *args, **kwargs)
except (daklib.archive.ArchiveException, daklib.checks.Reject) as e:
pu.changes = open(upload.changes.path, 'r').read()
pu.changes_filename = upload.changes.filename
pu.changes = open(upload.changes.path, 'r').read()
pu.changes_filename = upload.changes.filename
pu.source = control.get('Source')
pu.version = control.get('Version')
pu.architecture = control.get('Architecture')
pu.source = control.get('Source')
pu.version = control.get('Version')
pu.architecture = control.get('Architecture')
-def process_it(directory, changes, keyrings, session):
+def process_it(directory, changes, keyrings):
with daklib.archive.ArchiveUpload(directory, changes, keyrings) as upload:
processed = action(directory, upload)
if processed and not Options['No-Action']:
with daklib.archive.ArchiveUpload(directory, changes, keyrings) as upload:
processed = action(directory, upload)
if processed and not Options['No-Action']:
unlink_if_exists(os.path.join(directory, changes.filename))
for fn in changes.files:
unlink_if_exists(os.path.join(directory, fn))
unlink_if_exists(os.path.join(directory, changes.filename))
for fn in changes.files:
unlink_if_exists(os.path.join(directory, fn))
session = DBConn().session()
keyrings = session.query(Keyring).filter_by(active=True).order_by(Keyring.priority)
keyring_files = [ k.keyring_name for k in keyrings ]
session = DBConn().session()
keyrings = session.query(Keyring).filter_by(active=True).order_by(Keyring.priority)
keyring_files = [ k.keyring_name for k in keyrings ]
changes.sort(key=lambda x: x[1])
for directory, c in changes:
changes.sort(key=lambda x: x[1])
for directory, c in changes: