diff options
Diffstat (limited to 'src/buildstream/_scheduler/queues/trackqueue.py')
| -rw-r--r-- | src/buildstream/_scheduler/queues/trackqueue.py | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/src/buildstream/_scheduler/queues/trackqueue.py b/src/buildstream/_scheduler/queues/trackqueue.py index 194bb7e1d..6bdf838f9 100644 --- a/src/buildstream/_scheduler/queues/trackqueue.py +++ b/src/buildstream/_scheduler/queues/trackqueue.py @@ -35,8 +35,8 @@ class TrackQueue(Queue): complete_name = "Tracked" resources = [ResourceType.DOWNLOAD] - def process(self, element): - return element._track() + def get_process_func(self): + return TrackQueue._track_element def status(self, element): # We can skip elements entirely if they have no sources. @@ -60,3 +60,7 @@ class TrackQueue(Queue): source._set_ref(new_ref, save=True) element._tracking_done() + + @staticmethod + def _track_element(element): + return element._track() |