From b15d41c6d6324e343fbea19abaed3717417f3cde Mon Sep 17 00:00:00 2001 From: Yuheng Long Date: Thu, 25 Jul 2013 10:02:36 -0700 Subject: Add the task module. BUG=None TEST=unit testings for the pipeline stage, pipeline workers, generation, steering and task. Change-Id: I38987a12d7a48ec027d42465300a7226c760ea9d Reviewed-on: https://gerrit-int.chromium.org/41659 Reviewed-by: Simon Que Commit-Queue: Yuheng Long Tested-by: Yuheng Long --- bestflags/steering.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'bestflags/steering.py') diff --git a/bestflags/steering.py b/bestflags/steering.py index 09c78387..2f889ca1 100644 --- a/bestflags/steering.py +++ b/bestflags/steering.py @@ -73,12 +73,13 @@ def Steering(cache, generations, input_queue, result_queue): # If there is a task whose result is ready from the last stage of the # feedback loop, there will be one less pending task. + task = input_queue.get() # Store the result of this ready task. Intermediate results can be used to # generate report for final result or be used to reboot from a crash from # the failure of any module of the framework. - task.CacheSteeringCost() + task.LogSteeringCost() # Find out which pending generation this ready task belongs to. This pending # generation will have one less pending task. The "next" expression iterates -- cgit v1.2.3