[Findit] Process analysis requests of Waterfall failures concurrently.

appengine/findit/handlers/process_failure_analysis_requests.py

Index: appengine/findit/handlers/process_failure_analysis_requests.py
diff --git a/appengine/findit/handlers/trigger_analyses.py b/appengine/findit/handlers/process_failure_analysis_requests.py
similarity index 83%
rename from appengine/findit/handlers/trigger_analyses.py
rename to appengine/findit/handlers/process_failure_analysis_requests.py
index f08f1ca8bf2c77e4a658d6cb5b7c2f4391ed9c0b..096c0b6e836d5cb501c418590decb349d8a133c4 100644
--- a/appengine/findit/handlers/trigger_analyses.py
+++ b/appengine/findit/handlers/process_failure_analysis_requests.py
@@ -3,6 +3,7 @@
 # found in the LICENSE file.
 
 import json
+import logging
 
 from common import constants
 from common.base_handler import BaseHandler
@@ -20,11 +21,13 @@ def _TriggerNewAnalysesOnDemand(builds):
     build_number = build['build_number']
     failed_steps = build.get('failed_steps')
 
-    # TODO(stgao): make builder_alerts send information of whether a build
+    # TODO(stgao): make alerts-dispatcher send information of whether a build
     # is completed.
     build = build_util.DownloadBuildData(
         master_name, builder_name, build_number)
     if not build or not build.data:
+      logging.error('Failed to retrieve build data for %s/%s/%s, steps=%s',
+                   master_name, builder_name, build_number, repr(failed_steps))
       continue  # Skip the build, wait for next request to recheck.
 
     build_info = buildbot.ExtractBuildInfo(
@@ -36,11 +39,11 @@ def _TriggerNewAnalysesOnDemand(builds):
         force=False, queue_name=constants.WATERFALL_ANALYSIS_QUEUE)
 
 
-class TriggerAnalyses(BaseHandler):
+class ProcessFailureAnalysisRequests(BaseHandler):
   """Triggers new analyses on demand.
 
   This handler checks the build failures in the request, and triggers new
-  analyes for a build in two situations:
+  analyses for a build in two situations:
   1. A new step failed.
   2. The build became completed after last analysis. This will potentially
      trigger a try-job run.