Changeset View
Changeset View
Standalone View
Standalone View
swh/lister/debian/lister.py
Show First 20 Lines • Show All 210 Lines • ▼ Show 20 Lines | def run(self): | ||||
""" | """ | ||||
distribution = self.db_session\ | distribution = self.db_session\ | ||||
.query(Distribution)\ | .query(Distribution)\ | ||||
.options(joinedload(Distribution.areas))\ | .options(joinedload(Distribution.areas))\ | ||||
.filter(Distribution.name == self.distribution)\ | .filter(Distribution.name == self.distribution)\ | ||||
.one_or_none() | .one_or_none() | ||||
if not distribution: | if not distribution: | ||||
raise ValueError("Distribution %s is not registered" % | logger.error("Distribution %s is not registered" % | ||||
self.distribution) | self.distribution) | ||||
return {'status': 'failed'} | |||||
if not distribution.type == 'deb': | if not distribution.type == 'deb': | ||||
raise ValueError("Distribution %s is not a Debian derivative" % | logger.error("Distribution %s is not a Debian derivative" % | ||||
distribution) | distribution) | ||||
return {'status': 'failed'} | |||||
date = self.date | date = self.date | ||||
logger.debug('Creating snapshot for distribution %s on date %s' % | logger.debug('Creating snapshot for distribution %s on date %s' % | ||||
(distribution, date)) | (distribution, date)) | ||||
snapshot = DistributionSnapshot(date=date, distribution=distribution) | snapshot = DistributionSnapshot(date=date, distribution=distribution) | ||||
Show All 12 Lines | def run(self): | ||||
self.db_session.add(area_snapshot) | self.db_session.add(area_snapshot) | ||||
area_snapshot.packages.extend(new_area_packages) | area_snapshot.packages.extend(new_area_packages) | ||||
area_snapshot.packages.extend(self.old_area_packages) | area_snapshot.packages.extend(self.old_area_packages) | ||||
self.create_tasks_for_snapshot(snapshot) | self.create_tasks_for_snapshot(snapshot) | ||||
self.db_session.commit() | self.db_session.commit() | ||||
return True | return {'status': 'eventful'} |