diff options
| author | Tiago Gomes <tiago.gomes@codethink.co.uk> | 2018-09-11 16:00:39 +0100 |
|---|---|---|
| committer | Abderrahim Kitouni <a.kitouni@gmail.com> | 2019-04-12 14:58:11 +0000 |
| commit | 1147e208f40ee7a9932c6d5413e8b46a97c01f74 (patch) | |
| tree | f7e3a8304b2270e0d53f9e1ca98cc5e0ba148906 | |
| parent | 5cb2076daddc464ddfb6d7c39b138fc174bc567f (diff) | |
| download | buildstream-1147e208f40ee7a9932c6d5413e8b46a97c01f74.tar.gz | |
scheduler: minor cleanups to CleanupJob
Remove unneeded cruft.
| -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 2975f9758..86a406430 100644 --- a/buildstream/_scheduler/scheduler.py +++ b/buildstream/_scheduler/scheduler.py @@ -355,8 +355,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() |