Create Tasks.Tags endpoint and Cron job

appengine/swarming/server/task_result.py

 # Copyright 2014 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.
 
 """Task execution result models.
 
 This module doesn't do the scheduling itself. It only describes the entities to
 store tasks results.
 
 - TaskResultSummary represents the overall result for the TaskRequest taking in
@@ skipping 831 matching lines @@
         self.state != run_result.state or
         self.try_number != run_result.try_number)
 
   def to_dict(self):
     out = super(TaskResultSummary, self).to_dict()
     if out['properties_hash']:
       out['properties_hash'] = out['properties_hash'].encode('hex')
     return out
 
 
+class TagValues(ndb.Model):
+  tag = ndb.StringProperty()
+  values = ndb.StringProperty(repeated=True)
+
+
+class TagAggregation(ndb.Model):
+  """Has all dimensions that are currently in use."""
+  tags = ndb.LocalStructuredProperty(TagValues, repeated=True)
+
+  ts = ndb.DateTimeProperty()
+
+  # We only store one of these entities. Use this key to refer to any instance.
+  KEY = ndb.Key('TagAggregation', 'current')
+
+
 ### Private stuff.
 
 
 def _run_result_key_to_output_key(run_result_key):
   """Returns a ndb.key to a TaskOutput."""
   assert run_result_key.kind() == 'TaskRunResult', run_result_key
   return ndb.Key(TaskOutput, 1, parent=run_result_key)
 
 
 def _output_key_to_output_chunk_key(output_key, chunk_number):
@@ skipping 284 matching lines @@
   if tags:
     # Add TaskResultSummary indexes if desired.
     if sort != 'created_ts':
       raise ValueError(
           'Add needed indexes for sort:%s and tags if desired' % sort)
     tags_filter = TaskResultSummary.tags == tags[0]
     for tag in tags[1:]:
       tags_filter = ndb.AND(tags_filter, TaskResultSummary.tags == tag)
     query = query.filter(tags_filter)
   return _filter_query(TaskResultSummary, query, start, end, sort, state)