| Index: appengine/findit/waterfall/test/process_base_swarming_task_result_pipeline_test.py
|
| diff --git a/appengine/findit/waterfall/test/process_base_swarming_task_result_pipeline_test.py b/appengine/findit/waterfall/test/process_base_swarming_task_result_pipeline_test.py
|
| index 3fd7a92c03bd1ca70bade39213ce8d78d7abf1bc..a443586c397bd72f37b7e2ea3090acf033275aa6 100644
|
| --- a/appengine/findit/waterfall/test/process_base_swarming_task_result_pipeline_test.py
|
| +++ b/appengine/findit/waterfall/test/process_base_swarming_task_result_pipeline_test.py
|
| @@ -116,6 +116,10 @@ _SWARMING_TASK_RESULTS = {
|
| 'state': 'COMPLETED',
|
| 'exit_code': '2', # Swarming task failed.
|
| },
|
| + 'task_id4': {
|
| + 'state': 'COMPLETED',
|
| + 'exit_code': '1',
|
| + },
|
| }
|
|
|
|
|
| @@ -296,6 +300,25 @@ class ProcessBaseSwarmingTaskResultPipelineTest(wf_testcase.WaterfallTestCase):
|
| swarming_util.TASK_FAILED]
|
| })
|
|
|
| + def testMonitorSwarmingTaskWhereNoTaskOutputs(self):
|
| + task = WfSwarmingTask.Create(
|
| + self.master_name, self.builder_name,
|
| + self.build_number, self.step_name)
|
| + task.task_id = 'task_id4'
|
| + task.put()
|
| +
|
| + pipeline = ProcessSwarmingTaskResultPipeline()
|
| + pipeline.run(
|
| + self.master_name, self.builder_name, self.build_number, self.step_name)
|
| +
|
| + self.assertEqual(analysis_status.ERROR, task.status)
|
| + self.assertEqual(
|
| + task.error,
|
| + {
|
| + 'code': swarming_util.NO_TASK_OUTPUTS,
|
| + 'message': 'outputs_ref is None'
|
| + })
|
| +
|
| def testProcessSwarmingTaskResultPipeline(self):
|
| # End to end test.
|
| self.mock(swarming_util, 'GetSwarmingTaskFailureLog',
|
|
|