diff options
-rw-r--r-- | buildstream/_scheduler/jobs/cleanupjob.py | 9 | ||||
-rw-r--r-- | buildstream/_scheduler/scheduler.py | 3 |
2 files changed, 2 insertions, 10 deletions
diff --git a/buildstream/_scheduler/jobs/cleanupjob.py b/buildstream/_scheduler/jobs/cleanupjob.py index c22ce3b98..399435ad9 100644 --- a/buildstream/_scheduler/jobs/cleanupjob.py +++ b/buildstream/_scheduler/jobs/cleanupjob.py @@ -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 @@ -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 {} diff --git a/buildstream/_scheduler/scheduler.py b/buildstream/_scheduler/scheduler.py index de544bce7..8faf58e65 100644 --- a/buildstream/_scheduler/scheduler.py +++ b/buildstream/_scheduler/scheduler.py @@ -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() |