[Findit] Adding schedule_flake_try_job_pipeline.py to trigger flake try jobs

appengine/findit/waterfall/flake/test/schedule_flake_try_job_pipeline_test.py

+# Copyright 2016 The Chromium Authors. All rights reserved.
+# Use of this source code is governed by a BSD-style license that can be
+# found in the LICENSE file.
+
+import mock
+
+from common.waterfall import buildbucket_client
+from model.flake.flake_try_job import FlakeTryJob
+from model.flake.flake_try_job_data import FlakeTryJobData
+from waterfall import schedule_try_job_pipeline
+from waterfall.flake.schedule_flake_try_job_pipeline import (
+    ScheduleFlakeTryJobPipeline)
+from waterfall.test import wf_testcase
+
+
+class ScheduleFlakeTryJobPipelineTest(wf_testcase.WaterfallTestCase):
+
+  def testGetBuildProperties(self):
+    self.UpdateUnitTestConfigSettings(
+        config_property='check_flake_settings',
+        override_data={'iterations_to_rerun': 100})
+    master_name = 'm'
+    builder_name = 'b'
+    step_name = 's'
+    test_name = 't'
+    git_hash = 'a1b2c3d4'
+
+    expected_properties = {
+        'recipe': 'findit/chromium/flake',
+        'target_mastername': master_name,
+        'target_testername': builder_name,
+        'test_revision': git_hash,
+        'test_repeat_count': 100,
+        'tests': {
+            step_name: [test_name]
+        }
+    }
+
+    try_job_pipeline = ScheduleFlakeTryJobPipeline()
+    properties = try_job_pipeline._GetBuildProperties(
+        master_name, builder_name, step_name, test_name, git_hash)
+
+    self.assertEqual(properties, expected_properties)
+
+  def testCreateTryJobData(self):
+    master_name = 'm'
+    builder_name = 'b'
+    step_name = 's'
+    test_name = 't'
+    git_hash = 'a1b2c3d4'
+    build_id = 'build_id'
+
+    try_job = FlakeTryJob.Create(
+        master_name, builder_name, step_name, test_name, git_hash)
+    ScheduleFlakeTryJobPipeline()._CreateTryJobData(build_id, try_job.key)
+
+    try_job_data = FlakeTryJobData.Get(build_id)
+
+    self.assertEqual(try_job_data.try_job_key, try_job.key)
+
+  @mock.patch.object(schedule_try_job_pipeline, 'buildbucket_client')
+  def testScheduleFlakeTryJob(self, mock_module):
+    master_name = 'm'
+    builder_name = 'b'
+    step_name = 's'
+    test_name = 't'
+    git_hash = 'a1b2c3d4'
+    build_id = '1'
+    url = 'url'
+
+    response = {
+        'build': {
+            'id': build_id,
+            'url': url,
+            'status': 'SCHEDULED',
+        }
+    }
+    results = [(None, buildbucket_client.BuildbucketBuild(response['build']))]
+    mock_module.TriggerTryJobs.return_value = results
+
+    FlakeTryJob.Create(
+        master_name, builder_name, step_name, test_name, git_hash).put()
+
+    try_job_pipeline = ScheduleFlakeTryJobPipeline()
+    try_job_id = try_job_pipeline.run(
+        master_name, builder_name, step_name, test_name, git_hash)
+
+    try_job = FlakeTryJob.Get(
+        master_name, builder_name, step_name, test_name, git_hash)
+    try_job_data = FlakeTryJobData.Get(build_id)
+
+    self.assertEqual(build_id, try_job_id)
+    self.assertEqual(build_id, try_job.flake_results[-1]['try_job_id'])
+    self.assertTrue(build_id in try_job.try_job_ids)
+    self.assertEqual(try_job_data.try_job_key, try_job.key)