self.stampcache = {}
self.holdoff_tasks = set()
+ self.holdoff_need_update = True
self.sqdone = False
self.stats = RunQueueStats(len(self.rqdata.runtaskentries))
self.rq.state = runQueueComplete
return True
+ self.update_holdofftasks()
+
if self.cooker.configuration.setsceneonly:
task = None
else:
return taskdepdata
def update_holdofftasks(self):
+
+ if not self.holdoff_need_update:
+ return
self.holdoff_tasks = set()
for tid in self.rqdata.runq_setscene_tids:
if dep not in self.runq_complete:
self.holdoff_tasks.add(dep)
+ self.holdoff_need_update = False
+
def process_possible_migrations(self):
changed = set()
self.sqdone = False
if changed:
- self.update_holdofftasks()
+ self.holdoff_need_update = True
def scenequeue_updatecounters(self, task, fail=False):
self.tasks_covered = covered
self.tasks_notcovered = notcovered
- self.update_holdofftasks()
+ self.holdoff_need_update = True
def sq_task_completeoutright(self, task):
"""