diff options
Diffstat (limited to 'src/buildstream/_scheduler/queues/buildqueue.py')
| -rw-r--r-- | src/buildstream/_scheduler/queues/buildqueue.py | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/src/buildstream/_scheduler/queues/buildqueue.py b/src/buildstream/_scheduler/queues/buildqueue.py index b280661cc..1dd45607b 100644 --- a/src/buildstream/_scheduler/queues/buildqueue.py +++ b/src/buildstream/_scheduler/queues/buildqueue.py @@ -57,7 +57,7 @@ class BuildQueue(Queue): logfile=logfile) job = ElementJob(self._scheduler, self.action_name, logfile, element=element, queue=self, - action_cb=self.process, + action_cb=self.get_process_func(), complete_cb=self._job_done, max_retries=self._max_retries) self._done_queue.append(element) @@ -66,8 +66,8 @@ class BuildQueue(Queue): return super().enqueue(to_queue) - def process(self, element): - return element._assemble() + def get_process_func(self): + return BuildQueue._assemble_element def status(self, element): if element._cached_success(): @@ -115,3 +115,7 @@ class BuildQueue(Queue): # Set a "buildable" callback for an element not yet ready # to be processed in the build queue. element._set_buildable_callback(self._enqueue_element) + + @staticmethod + def _assemble_element(element): + return element._assemble() |