DMC/play-daemon-threaded
12
0
Fork 0
Code Issues2 Pull Requests Projects Releases Wiki Activity

Added logging when deleting job files

Browse Source
This commit is contained in:
Erik Thuning 2024-01-18 10:32:13 +01:00
parent d28be73e2c
commit bb76807921
1 changed files with 7 additions and 0 deletions

7
pipeline/collector.py

@ -149,6 +149,9 @@ class Tracker:
Utility class to represent pending actions.
"""
def __init__(self, pending_item):
self.logger = self.logger = logging.getLogger(
f'play-daemon.{self.__class__.__name__}')
self.jobid = pending_item.jobid
self.jobspec = pending_item.jobspec
self.temp_copy = pending_item.package
self.handlers = pending_item.handlers
@ -173,9 +176,13 @@ class Tracker:
# Clean up uploaded files once all handlers are done with the job
# Failed jobs get cleaned manually for safety
if 'upload_dir' in self.jobspec and not self.failed:
self.logger.info("Deleting incoming files for job %s (%s)",
self.jobid, self.jobspec['upload_dir'])
rmtree(self.jobspec['upload_dir'])
# Also remove the temporary copy of the previous package state
if path.exists(self.temp_copy.basedir):
self.logger.info("Deleting temporary files for job %s (%s)",
self.jobid, self.temp_copy.basedir)
rmtree(self.temp_copy.basedir)
return True
else: