Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(863)

Side by Side Diff: appengine/findit/waterfall/trigger_base_swarming_task_pipeline.py

Issue 2538373003: [Culprit-Finder] Merge lib/ to libs/. (Closed)
Patch Set: . Created 4 years ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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 import logging 6 import logging
7 import time 7 import time
8 8
9 from common.http_client_appengine import HttpClientAppengine as HttpClient 9 from common.http_client_appengine import HttpClientAppengine as HttpClient
10 from common.pipeline_wrapper import BasePipeline 10 from common.pipeline_wrapper import BasePipeline
11 from lib import time_util 11 from libs import time_util
12 from model import analysis_status 12 from model import analysis_status
13 from waterfall import swarming_util 13 from waterfall import swarming_util
14 from waterfall import waterfall_config 14 from waterfall import waterfall_config
15 15
16 16
17 class TriggerBaseSwarmingTaskPipeline(BasePipeline): # pragma: no cover. 17 class TriggerBaseSwarmingTaskPipeline(BasePipeline): # pragma: no cover.
18 """A pipeline to trigger a Swarming task to re-run selected tests of a step. 18 """A pipeline to trigger a Swarming task to re-run selected tests of a step.
19 19
20 This pipeline only supports test steps that run on Swarming and support the 20 This pipeline only supports test steps that run on Swarming and support the
21 gtest filter. 21 gtest filter.
(...skipping 206 matching lines...) Expand 10 before | Expand all | Expand 10 after
228 swarming_task.error = error 228 swarming_task.error = error
229 else: 229 else:
230 logging.info('A Swarming task was triggered:%s', task_id) 230 logging.info('A Swarming task was triggered:%s', task_id)
231 231
232 swarming_task.put() 232 swarming_task.put()
233 233
234 # Call the hook function after the task is triggered. 234 # Call the hook function after the task is triggered.
235 self._OnTaskTriggered() 235 self._OnTaskTriggered()
236 236
237 return task_id 237 return task_id
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698