diff options
| author | Yuheng Long <yuhenglong@google.com> | 2013-07-25 10:02:36 -0700 |
|---|---|---|
| committer | ChromeBot <chrome-bot@google.com> | 2013-07-30 17:08:54 -0700 |
| commit | b15d41c6d6324e343fbea19abaed3717417f3cde (patch) | |
| tree | afbdbad72db0734112a0860bc778de6192562924 /bestflags/steering.py | |
| parent | a5712a2c71aa665dcca808963d152228890c8364 (diff) | |
| download | toolchain-utils-b15d41c6d6324e343fbea19abaed3717417f3cde.tar.gz | |
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 <sque@google.com>
Commit-Queue: Yuheng Long <yuhenglong@google.com>
Tested-by: Yuheng Long <yuhenglong@google.com>
Diffstat (limited to 'bestflags/steering.py')
| -rw-r--r-- | bestflags/steering.py | 3 |
1 files changed, 2 insertions, 1 deletions
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 |