diff options
Diffstat (limited to 'src/buildstream/_scheduler/queues/buildqueue.py')
| -rw-r--r-- | src/buildstream/_scheduler/queues/buildqueue.py | 11 |
1 files changed, 3 insertions, 8 deletions
diff --git a/src/buildstream/_scheduler/queues/buildqueue.py b/src/buildstream/_scheduler/queues/buildqueue.py index 1dd45607b..1be3f7cd0 100644 --- a/src/buildstream/_scheduler/queues/buildqueue.py +++ b/src/buildstream/_scheduler/queues/buildqueue.py @@ -21,7 +21,7 @@ from datetime import timedelta from . import Queue, QueueStatus -from ..jobs import ElementJob, JobStatus +from ..jobs import JobStatus from ..resources import ResourceType from ..._message import MessageType @@ -55,14 +55,9 @@ class BuildQueue(Queue): detail=detail, action_name=self.action_name, elapsed=timedelta(seconds=0), logfile=logfile) - job = ElementJob(self._scheduler, self.action_name, - logfile, element=element, queue=self, - action_cb=self.get_process_func(), - complete_cb=self._job_done, - max_retries=self._max_retries) self._done_queue.append(element) - self.failed_elements.append(element) - self._scheduler._job_complete_callback(job, False) + element_name = element._get_full_name() + self._task_group.add_failed_task(element_name) return super().enqueue(to_queue) |