if obey_policy_queue and target.policy_queue_id is not None:
raise Exception('Not implemented...')
- self.logger = None if dry_run else daklog.Logger("update-suite")
+ self.logger = None if dry_run else daklib.daklog.Logger("update-suite")
def query_new_binaries(self, additional_sources):
# Candidates are binaries in the origin suite, and optionally in its policy queue.
.filter(ArchiveFile.archive_id == suite.archive_id)
def install_binaries(self, binaries, suite):
+ if len(binaries) == 0:
+ return
# If origin and target suites are in the same archive, we can skip the
# overhead from ArchiveTransaction.copy_binary()
if self.origin.archive_id == suite.archive_id:
.filter(ArchiveFile.archive_id == suite.archive_id)
def install_sources(self, sources, suite):
+ if len(sources) == 0:
+ return
# If origin and target suites are in the same archive, we can skip the
# overhead from ArchiveTransaction.copy_source()
if self.origin.archive_id == suite.archive_id:
def update_suite(self):
targets = set([self.target])
if self.obey_build_queues:
- targets.update(self.target.copy_queues)
+ targets.update([bq.suite for bq in self.target.copy_queues])
target_names = [ s.suite_name for s in targets ]
target_names.sort()
target_name = ",".join(target_names)