[Findit] Hacky solution to map a CQ trybot step to a Waterfall buildbot step.

appengine/findit/waterfall/trigger_base_swarming_task_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.
 
 import copy
 import logging
 import time
 
 from common import time_util
 from common.http_client_appengine import HttpClientAppengine as HttpClient
@@ skipping 133 matching lines @@
     call_args = self._GetArgs(master_name, builder_name,
                               build_number, step_name, tests)
     # Check if a new Swarming Task is really needed.
     if not self._NeedANewSwarmingTask(*call_args):
       return self._GetSwarmingTaskId(*call_args)
     assert tests
     http_client = HttpClient()
 
     # 0. Retrieve existing Swarming task ids for the given step.
     swarming_task_items = swarming_util.ListSwarmingTasksDataByTags(
-        master_name, builder_name, build_number, http_client, step_name)
+        master_name, builder_name, build_number, http_client,
+        {'stepname': step_name})
     assert len(swarming_task_items) > 0, 'No Swarming task was run.'
     ref_task_id = swarming_task_items[0]['task_id']
 
     # 1. Retrieve Swarming task parameters from a given Swarming task id.
     ref_request = swarming_util.GetSwarmingTaskRequest(
         ref_task_id, http_client)
 
     # 2. Update/Overwrite parameters for the re-run.
     iterations_to_rerun = self._GetIterationsToRerun()
 
     new_request = self._CreateNewSwarmingTaskRequest(
         ref_task_id, ref_request, master_name, builder_name, build_number,
         step_name, tests, iterations_to_rerun)
 
     # 3. Trigger a new Swarming task to re-run the failed tests.
     task_id = swarming_util.TriggerSwarmingTask(new_request, http_client)
 
     # Save the task id.
     swarming_task = self._GetSwarmingTask(*call_args)
     swarming_task.task_id = task_id
     swarming_task.parameters['tests'] = tests
     swarming_task.parameters['iterations_to_rerun'] = iterations_to_rerun
     swarming_task.parameters['ref_name'] = swarming_util.GetTagValue(
         new_request.tags, 'ref_name')
     swarming_task.put()
 
     logging.info('A Swarming task was triggered:%s', task_id)
     return task_id