Include "revision" tag for all Swarming tasks

infra/bots/recipe_modules/skia_swarming/api.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 recipe_engine import recipe_api
 import shlex
 
 
 DEFAULT_TASK_EXPIRATION = 20*60*60
@@ skipping 205 matching lines @@
       swarming_task.idempotent = idempotent
       swarming_task.priority = 90
       swarming_task.expiration = (
           expiration if expiration else DEFAULT_TASK_EXPIRATION)
       swarming_task.hard_timeout = (
           hard_timeout if hard_timeout else DEFAULT_TASK_TIMEOUT)
       swarming_task.io_timeout = (
           io_timeout if io_timeout else DEFAULT_IO_TIMEOUT)
       if extra_args:
         swarming_task.extra_args = extra_args
+      revision = self.m.properties.get('revision')
+      if revision:
+        swarming_task.tags.add('revision:%s' % revision)
       swarming_tasks.append(swarming_task)
     step_results = self.m.swarming.trigger(swarming_tasks)
     for step_result in step_results:
       self._add_log_links(step_result)
     return swarming_tasks
 
   def collect_swarming_task(self, swarming_task):
     """Collects the specified swarming task.
 
     Args:
@@ skipping 40 matching lines @@
     else:
       for _, task in step_result.json.output.get('tasks', {}).iteritems():
         ids.append(task['task_id'])
     for idx, task_id in enumerate(ids):
       link = MILO_LOG_LINK % task_id
       k = 'view steps on Milo'
       if len(ids) > 1:  # pragma: nocover
         k += ' (shard index %d, %d total)' % (idx, len(ids))
       step_result.presentation.links[k] = link