almalinux/pungi
14
1
Fork 0
Code Issues Pull Requests Releases Activity

Send more messages in createiso phase

Browse Source 
When phase starts, a message is sent with list of images that are going
to be built. As each images is finished (or fails), another message
announces that status.

Signed-off-by: Lubomír Sedlář <lsedlar@redhat.com>
This commit is contained in:
Lubomír Sedlář 2015-11-25 15:17:52 +01:00
parent 066855a039
commit 7ce5c76673
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
pungi/phases/createiso.py
View File

@ -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):