| OLD | NEW |
| 1 # Copyright 2016 The Chromium Authors. All rights reserved. | 1 # Copyright 2016 The Chromium Authors. All rights reserved. |
| 2 # Use of this source code is governed by a BSD-style license that can be | 2 # Use of this source code is governed by a BSD-style license that can be |
| 3 # found in the LICENSE file. | 3 # found in the LICENSE file. |
| 4 | 4 |
| 5 import copy | 5 import copy |
| 6 from datetime import datetime | 6 from datetime import datetime |
| 7 import logging | 7 import logging |
| 8 import time | 8 import time |
| 9 | 9 |
| 10 from google.appengine.ext import ndb | 10 from google.appengine.ext import ndb |
| (...skipping 140 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 151 | 151 |
| 152 # 3. Trigger a new Swarming task to re-run the failed tests. | 152 # 3. Trigger a new Swarming task to re-run the failed tests. |
| 153 task_id = swarming_util.TriggerSwarmingTask(new_request, http_client) | 153 task_id = swarming_util.TriggerSwarmingTask(new_request, http_client) |
| 154 | 154 |
| 155 # Save the task id. | 155 # Save the task id. |
| 156 swarming_task = WfSwarmingTask.Get( | 156 swarming_task = WfSwarmingTask.Get( |
| 157 master_name, builder_name, build_number, step_name) | 157 master_name, builder_name, build_number, step_name) |
| 158 swarming_task.task_id = task_id | 158 swarming_task.task_id = task_id |
| 159 swarming_task.parameters['tests'] = tests | 159 swarming_task.parameters['tests'] = tests |
| 160 swarming_task.parameters['iterations_to_rerun'] = iterations_to_rerun | 160 swarming_task.parameters['iterations_to_rerun'] = iterations_to_rerun |
| 161 swarming_task.parameters['ref_name'] = swarming_util.GetTagValue( |
| 162 new_request.tags, 'ref_name') |
| 161 swarming_task.put() | 163 swarming_task.put() |
| 162 | 164 |
| 163 logging.info('A Swarming task was triggered:%s', task_id) | 165 logging.info('A Swarming task was triggered:%s', task_id) |
| 164 return task_id | 166 return task_id |
| OLD | NEW |