Add CIPD pin reporting to swarming.

appengine/swarming/swarming_rpcs.py

 # Copyright 2015 The LUCI Authors. All rights reserved.
 # Use of this source code is governed under the Apache License, Version 2.0
 # that can be found in the LICENSE file.
 
 """This module defines ProtoRPC types for the Swarming Server handlers."""
 
 from protorpc import message_types
 from protorpc import messages
 
 
@@ skipping 125 matching lines @@
   # CIPD package of CIPD client to use.
   # client_package.version is required.
   # This field is optional is default value is defined in the server config.
   # client_package.path must be empty.
   client_package = messages.MessageField(CipdPackage, 2)
 
   # List of CIPD packages to install in $CIPD_PATH prior task execution.
   packages = messages.MessageField(CipdPackage, 3, repeated=True)
 
 
+class CipdPins(messages.Message):
+  """Defines pinned CIPD packages that were installed during the task."""
+
+  # The pinned package + version of the CIPD client that was actually used.
+  client_package = messages.MessageField(CipdPackage, 1)
+
+  # List of CIPD packages that were installed in the task with fully resolved
+  # package names and versions.
+  packages = messages.MessageField(CipdPackage, 2, repeated=True)
+
+
 class TaskProperties(messages.Message):
   """Important metadata about a particular task."""
   cipd_input = messages.MessageField(CipdInput, 10)
   command = messages.StringField(1, repeated=True)
   dimensions = messages.MessageField(StringPair, 2, repeated=True)
   env = messages.MessageField(StringPair, 3, repeated=True)
   execution_timeout_secs = messages.IntegerField(4)
   extra_args = messages.StringField(5, repeated=True)
   grace_period_secs = messages.IntegerField(6)
   idempotent = messages.BooleanField(7)
@@ skipping 127 matching lines @@
   costs_usd = messages.FloatField(22, repeated=True)
   # Only in TaskResultSummary.
   name = messages.StringField(23)
   # Only in TaskResultSummary.
   tags = messages.StringField(24, repeated=True)
   # Only in TaskResultSummary.
   user = messages.StringField(25)
   # Statistics about overhead for an isolated task. Only sent when requested.
   performance_stats = messages.MessageField(PerformanceStats, 26)
 
+  # A listing of the ACTUAL pinned CipdPackages that the task used. These can
+  # vary from the input packages if the inputs included non-identity versions
+  # (e.g. a ref like "latest").
+  cipd_pins = messages.MessageField(CipdPins, 27)
+
 
 class TaskList(messages.Message):
   """Wraps a list of TaskResult."""
   # TODO(maruel): Rename to TaskResults.
   cursor = messages.StringField(1)
   items = messages.MessageField(TaskResult, 2, repeated=True)
   now = message_types.DateTimeField(3)
 
 
 class TaskRequests(messages.Message):
@@ skipping 164 matching lines @@
 
 
 class DeletedResponse(messages.Message):
   """Indicates whether a bot was deleted."""
   deleted = messages.BooleanField(1)
 
 
 class TerminateResponse(messages.Message):
   """Returns the pseudo taskid to wait for the bot to shut down."""
   task_id = messages.StringField(1)