diff --git a/pungi/phases/createiso.py b/pungi/phases/createiso.py index ad78234b..9d27d2a1 100644 --- a/pungi/phases/createiso.py +++ b/pungi/phases/createiso.py @@ -55,6 +55,7 @@ class CreateisoPhase(PhaseBase): def run(self): iso = IsoWrapper(logger=self.compose._logger) symlink_isos_to = self.compose.conf.get("symlink_isos_to", None) + deliverables = [] commands = [] for variant in self.compose.get_variants(types=["variant", "layered-product", "optional"], recursive=True): @@ -97,6 +98,7 @@ class CreateisoPhase(PhaseBase): self.compose.log_warning("Skipping mkisofs, image already exists: %s" % iso_path) continue iso_name = os.path.basename(iso_path) + deliverables.append(iso_path) graft_points = prepare_iso(self.compose, arch, variant, disc_num=disc_num, disc_count=disc_count, split_iso_data=iso_data) @@ -180,6 +182,8 @@ class CreateisoPhase(PhaseBase): cmd["cmd"] = " && ".join(cmd["cmd"]) commands.append(cmd) + self.compose.notifier.send('createiso-targets', deliverables=deliverables) + for cmd in commands: self.pool.add(CreateIsoThread(self.pool)) self.pool.queue_put((self.compose, cmd)) @@ -201,6 +205,10 @@ class CreateIsoThread(WorkerThread): # TODO: remove jigdo & template & checksums except OSError: pass + compose.notifier.send('createiso-imagefail', + file=cmd['iso_path'], + arch=cmd['arch'], + variant=str(cmd['variant'])) def process(self, item, num): compose, cmd = item @@ -294,6 +302,10 @@ class CreateIsoThread(WorkerThread): # add: boot.iso self.pool.log_info("[DONE ] %s" % msg) + compose.notifier.send('createiso-imagedone', + file=cmd['iso_path'], + arch=cmd['arch'], + variant=str(cmd['variant'])) def split_iso(compose, arch, variant):