Loading buildstream/_scheduler/jobs/cleanupjob.py +1 −8 Original line number Diff line number Diff line Loading @@ -21,9 +21,8 @@ from ..._platform import Platform class CleanupJob(Job): def __init__(self, *args, complete_cb, **kwargs): def __init__(self, *args, **kwargs): super().__init__(*args, **kwargs) self._complete_cb = complete_cb platform = Platform.get_platform() self._artifacts = platform.artifactcache Loading @@ -34,9 +33,3 @@ class CleanupJob(Job): def parent_complete(self, success, result): if success: self._artifacts.set_cache_size(result) if self._complete_cb: self._complete_cb() def child_process_data(self): return {} buildstream/_scheduler/scheduler.py +1 −2 Original line number Diff line number Diff line Loading @@ -357,8 +357,7 @@ class Scheduler(): job = CleanupJob(self, 'cleanup', 'cleanup/cleanup', resources=[ResourceType.CACHE, ResourceType.PROCESS], exclusive_resources=[ResourceType.CACHE], complete_cb=None) exclusive_resources=[ResourceType.CACHE]) self.schedule_jobs([job]) # _suspend_jobs() Loading Loading
buildstream/_scheduler/jobs/cleanupjob.py +1 −8 Original line number Diff line number Diff line Loading @@ -21,9 +21,8 @@ from ..._platform import Platform class CleanupJob(Job): def __init__(self, *args, complete_cb, **kwargs): def __init__(self, *args, **kwargs): super().__init__(*args, **kwargs) self._complete_cb = complete_cb platform = Platform.get_platform() self._artifacts = platform.artifactcache Loading @@ -34,9 +33,3 @@ class CleanupJob(Job): def parent_complete(self, success, result): if success: self._artifacts.set_cache_size(result) if self._complete_cb: self._complete_cb() def child_process_data(self): return {}
buildstream/_scheduler/scheduler.py +1 −2 Original line number Diff line number Diff line Loading @@ -357,8 +357,7 @@ class Scheduler(): job = CleanupJob(self, 'cleanup', 'cleanup/cleanup', resources=[ResourceType.CACHE, ResourceType.PROCESS], exclusive_resources=[ResourceType.CACHE], complete_cb=None) exclusive_resources=[ResourceType.CACHE]) self.schedule_jobs([job]) # _suspend_jobs() Loading