[Findit] Strip platform from step_name before triggering try job.

appengine/findit/waterfall/run_try_job_for_reliable_failure_pipeline.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.
 
 from collections import defaultdict
 import logging
 
 from common import appengine_util
 from model import wf_analysis_status
 from model.wf_try_job import WfTryJob
 from pipeline_wrapper import BasePipeline
 from pipeline_wrapper import pipeline
 from waterfall import try_job_pipeline
 from waterfall.try_job_type import TryJobType
 
 
 # TODO(chanli): Need to figure out why try-job-queue doesn't work.
 TRY_JOB_PIPELINE_QUEUE_NAME = 'build-failure-analysis-queue'
 
 
 def _GetReliableTargetedTests(targeted_tests, classified_tests_by_step):
   """Returns a dict containing a list of reliable tests for each failed step."""
   reliable_tests = defaultdict(list)
   for step_name, tests in targeted_tests.iteritems():
     if step_name in classified_tests_by_step:  # Swarming step.
       # If the step is swarming but there is no result for it, it's highly
       # likely that there is some error with the task.
       # Thus skip this step for no insights from task to avoid false positive.
-      classified_tests = classified_tests_by_step[step_name]
+      step_name_no_platform = classified_tests_by_step[step_name][0]
+      classified_tests = classified_tests_by_step[step_name][1]
+
       for test in tests:
         if (test in classified_tests.get('reliable_tests', [])):
-          reliable_tests[step_name].append(test)
+          reliable_tests[step_name_no_platform].append(test)
     else:  # Non-swarming step, includes it directly.
       reliable_tests[step_name] = []
   return reliable_tests
 
 
 class RunTryJobForReliableFailurePipeline(BasePipeline):
   """A pipeline to trigger try job for reliable failures.
 
   Processes result from SwarmingTaskPipeline and start TryJobPipeline if there
   are reliable test failures.
@@ skipping 36 matching lines @@
                    master_name, builder_name, build_number,
                    new_try_job_pipeline.pipeline_status_path)
     else:  # pragma: no cover
       # No need to start try job, mark it as skipped.
       try_job_result = WfTryJob.Get(
           master_name, builder_name, build_number)
       if try_job_result:
         try_job_result.status = wf_analysis_status.SKIPPED
         try_job_result.put()
       return