status_logger: only send step data for whitelisted recipes (chromium_trybot)

scripts/master/status_logger.py

 # Copyright 2014 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.
 
 """Log status events to a file on disk or event collection endpoint."""
 
 
 import json
 import logging
 import logging.handlers
@@ skipping 476 matching lines @@
       scheduled = source_stamp.changes[0].when
 
     properties = build.getProperties()
     extra_result_code = properties.getProperty('extra_result_code')
     self.send_build_event(
         'END', finished * 1000, 'BUILD', bot, builderName, build_number,
         self._get_requested_at_millis(build),
         result=buildbot.status.results.Results[results],
         extra_result_code=extra_result_code)
 
+    # It's important that the recipe does not generate unbounded number
+    # of step names (e.g. one for each git revision), to avoid stream
+    # explosion in the monitoring system. Another alternative is for the recipe
+    # to clearly mark such dynamic steps - e.g. add "(dynamic)" to the name,
+    # and exclude such steps here.
+    WHITELISTED_RECIPES = [
+      'chromium_trybot',
+    ]
     steps_to_send = []
-    for step in build.getSteps():
-      step_started, step_finished = step.getTimes()
-      steps_to_send.append({
-        'step_name': step.getName(),
-        'duration_s': step_finished - step_started,
-        'result': buildbot.status.results.Results[step.getResults()[0]],
-      })
+    if properties.getProperty('recipe') in WHITELISTED_RECIPES:
+      for step in build.getSteps():
+        step_started, step_finished = step.getTimes()
+        steps_to_send.append({
+          'step_name': step.getName(),
+          'duration_s': step_finished - step_started,
+          'result': buildbot.status.results.Results[step.getResults()[0]],
+        })
 
     # If property doesn't exist, this function returns None.
     # Note: this is not true for build.getProperty(), it raises KeyError.
     project_id = properties.getProperty('patch_project')
     subproject_tag = properties.getProperty('subproject_tag')
     self.send_build_result(
         scheduled, started, finished, builderName, bot,
         buildbot.status.results.Results[results],
         project_id, subproject_tag, steps=steps_to_send)
 
   def builderRemoved(self, builderName):
     self.log('builderRemoved', '%s', builderName)
 
   def slaveConnected(self, slaveName):
     self.log('slaveConnected', '%s', slaveName)
 
   def slaveDisconnected(self, slaveName):
     self.log('slaveDisconnected', '%s', slaveName)