[Findit] Post analysis results of flakes to bug filed by chromium-try-flakes.

appengine/findit/waterfall/flake/flake_analysis_service.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 logging
 
 from common import constants
 from model.flake.flake_analysis_request import FlakeAnalysisRequest
 from waterfall.flake import initialize_flake_pipeline
 from waterfall.flake import step_mapper
+from waterfall.test_info import TestInfo
 
 
 def _CheckFlakeSwarmedAndSupported(request):
   """Checks if the flake is Swarmed and supported in any build step.
 
   Args:
     request (FlakeAnalysisRequest): The request to analyze a flake.
 
   Returns:
     (swarmed, supported, build_step)
@@ skipping 178 matching lines @@
   manually_triggered = user_email.endswith('@google.com')
 
   for build_step in request.build_steps:
     step_mapper.FindMatchingWaterfallStep(build_step)
 
   version_number, build_step = _CheckForNewAnalysis(request)
   if version_number and build_step:
     # A new analysis is needed.
     # TODO(lijeffrey): Add support for the force flag to trigger a rerun.
     logging.info('A new analysis is needed for: %s', build_step)
-    analysis = initialize_flake_pipeline.ScheduleAnalysisIfNeeded(
+    normalized_test = TestInfo(
         build_step.wf_master_name, build_step.wf_builder_name,
         build_step.wf_build_number, build_step.wf_step_name,
-        request.name, allow_new_analysis=True,
-        manually_triggered=manually_triggered, user_email=user_email,
-        triggering_source=triggering_source,
+        request.name)
+    original_test = TestInfo(
+        build_step.master_name, build_step.builder_name,
+        build_step.build_number, build_step.step_name,
+        request.name)
+    analysis = initialize_flake_pipeline.ScheduleAnalysisIfNeeded(
+        normalized_test, original_test, bug_id=request.bug_id,
+        allow_new_analysis=True, manually_triggered=manually_triggered,
+        user_email=user_email, triggering_source=triggering_source,
         queue_name=constants.WATERFALL_ANALYSIS_QUEUE)
     if analysis:
       # TODO: put this in a transaction.
       request = FlakeAnalysisRequest.GetVersion(
           key=request.name, version=version_number)
       request.analyses.append(analysis.key)
       request.put()
       logging.info('A new analysis was triggered successfully: %s',
                    analysis.key)
       return True
     else:
       logging.error('But new analysis was not triggered!')
   else:
     logging.info('No new analysis is needed: %s', request)
 
   return False