diff options
Diffstat (limited to 'buildstream/_scheduler/jobs/cachesizejob.py')
| -rw-r--r-- | buildstream/_scheduler/jobs/cachesizejob.py | 44 |
1 files changed, 0 insertions, 44 deletions
diff --git a/buildstream/_scheduler/jobs/cachesizejob.py b/buildstream/_scheduler/jobs/cachesizejob.py index ffb945e43..f73a09c74 100644 --- a/buildstream/_scheduler/jobs/cachesizejob.py +++ b/buildstream/_scheduler/jobs/cachesizejob.py @@ -16,12 +16,8 @@ # Author: # Tristan Daniël Maat <tristan.maat@codethink.co.uk> # -import os -from contextlib import contextmanager - from .job import Job from ..._platform import Platform -from ..._message import Message, MessageType class CacheSizeJob(Job): @@ -38,45 +34,5 @@ class CacheSizeJob(Job): if self._complete_cb: self._complete_cb(result) - @contextmanager - def child_logging_enabled(self, logfile): - self._logfile = logfile.format(pid=os.getpid()) - yield self._logfile - self._logfile = None - - def message(self, message_type, message, **kwargs): - args = dict(kwargs) - args['scheduler'] = True - self._scheduler.context.message(Message(None, message_type, message, **args)) - - def child_log(self, message): - with open(self._logfile, 'a+') as log: - INDENT = " " - EMPTYTIME = "--:--:--" - - template = "[{timecode: <8}] {type: <7} {name: <15}: {message}" - detail = '' - if message.detail is not None: - template += "\n\n{detail}" - detail = message.detail.rstrip('\n') - detail = INDENT + INDENT.join(detail.splitlines(True)) - - timecode = EMPTYTIME - if message.message_type in (MessageType.SUCCESS, MessageType.FAIL): - hours, remainder = divmod(int(message.elapsed.total_seconds()), 60**2) - minutes, seconds = divmod(remainder, 60) - timecode = "{0:02d}:{1:02d}:{2:02d}".format(hours, minutes, seconds) - - message_text = template.format(timecode=timecode, - type=message.message_type.upper(), - name='cache_size', - message=message.message, - detail=detail) - - log.write('{}\n'.format(message_text)) - log.flush() - - return message - def child_process_data(self): return {} |