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

appengine/findit/waterfall/test/trigger_swarming_task_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 time
 
 from testing_utils import testing
 
 from model import wf_analysis_status
 from model.wf_swarming_task import WfSwarmingTask
@@ skipping 93 matching lines @@
                   {'key': 'GTEST_SHARD_INDEX', 'value': '1'},
                   {'key': 'GTEST_TOTAL_SHARDS', 'value': '5'},
               ],
               'execution_timeout_secs': 3600,
               'extra_args': ['--flag=value', '--gtest_filter=d.f'],
               'grace_period_secs': 30,
               'idempotent': True,
               'inputs_ref': {'a': 1},
               'io_timeout_secs': 1200,
           },
-          'tags': ['master:a', 'buildername:b'],
+          'tags': ['master:a', 'buildername:b', 'name:a_tests'],
           'user': 'user',
       })
     self.mock(swarming_util, 'GetSwarmingTaskRequest',
               MockedGetSwarmingTaskRequest)
 
     new_request_json = {}
     def MockedTriggerSwarmingTask(new_request, *_):
       new_request_json.update(new_request.Serialize())
       return 'new_task_id'
     self.mock(swarming_util, 'TriggerSwarmingTask', MockedTriggerSwarmingTask)
 
     def MockedGetSwarmingTaskName(*_):
       return 'new_task_name'
     self.mock(trigger_swarming_task_pipeline, '_GetSwarmingTaskName',
               MockedGetSwarmingTaskName)
 
     self._MockGetSwarmingSettings()
 
     master_name = 'm'
     builder_name = 'b'
     build_number = 234
-    step_name = 's'
+    step_name = 'a_tests on platform'
     tests = ['a.b', 'a.c']
 
     expected_new_request_json = {
         'expiration_secs': 3600,
         'name': 'new_task_name',
         'parent_task_id': '',
         'priority': 25,
         'properties': {
             'command': 'cmd',
             'dimensions': [{'key': 'k', 'value': 'v'}],
             'env': [
                 {'key': 'a', 'value': '1'},
             ],
             'execution_timeout_secs': 3600,
             'extra_args': [
                 '--flag=value', '--gtest_repeat=10',
                 '--test-launcher-retry-limit=0',
                 '--gtest_filter=a.b:a.c'],
             'grace_period_secs': 30,
             'idempotent': False,
             'inputs_ref': {'a': 1},
             'io_timeout_secs': 1200,
         },
         'tags': ['purpose:deflake', 'ref_master:%s' % master_name,
                  'ref_buildername:%s' % builder_name,
                  'ref_buildnumber:%s' % build_number,
                  'ref_stepname:%s' % step_name,
-                 'ref_task_id:1'],
+                 'ref_task_id:1',
+                 'ref_name:a_tests'],
         'user': '',
     }
 
     pipeline = TriggerSwarmingTaskPipeline()
     new_task_id = pipeline.run(
         master_name, builder_name, build_number, step_name, tests)
     self.assertEqual('new_task_id', new_task_id)
     self.assertEqual(expected_new_request_json, new_request_json)
 
     swarming_task = WfSwarmingTask.Get(
         master_name, builder_name, build_number, step_name)
     self.assertIsNotNone(swarming_task)
     self.assertEqual('new_task_id', swarming_task.task_id)
     self.assertEqual(tests, swarming_task.parameters['tests'])
     self.assertEqual(_MOCK_SWARMING_SETTINGS['iterations_to_rerun'],
                      swarming_task.parameters['iterations_to_rerun'])