luci-py: roll infra_libs / gae_ts_mon to 4d74a66

client/third_party/infra_libs/event_mon/monitoring.py

 # Copyright 2015 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.
 
 import logging
 
 from google.protobuf.message import DecodeError
 from infra_libs.event_mon.protos.chrome_infra_log_pb2 import (
   ChromeInfraEvent, ServiceEvent, BuildEvent)
 from infra_libs.event_mon.protos.goma_stats_pb2 import GomaStats
@@ skipping 243 matching lines @@
                             code_version=code_version,
                             stack_trace=stack_trace).send()
 
 
 def get_build_event(event_type,
                     hostname,
                     build_name,
                     build_number=None,
                     build_scheduling_time=None,
                     step_name=None,
+                    step_text=None,
                     step_number=None,
                     result=None,
                     extra_result_code=None,
                     timestamp_kind=None,
                     event_timestamp=None,
                     service_name=None,
                     goma_stats=None,
                     goma_error=None,
                     goma_crash_report_id=None,
                     patch_url=None):
@@ skipping 49 matching lines @@
                     event.build_event.build_number)
   else: # no 'build_number' field
     if event.build_event.HasField('build_scheduling_time_ms'):
       logging.error('build_number has not been provided, '
                     'build_scheduling_time was provided (%s). '
                     'Both must be present or missing.',
                     event.build_event.build_scheduling_time_ms)
 
   if step_name:
     event.build_event.step_name = step_name
+  if step_text:
+    event.build_event.step_text = step_text
   if step_number is not None:
     event.build_event.step_number = step_number
   if patch_url is not None:
     event.build_event.patch_url = patch_url
 
   if event.build_event.step_name:
     if event_type != 'STEP':
       logging.error('step_name should be provided only for type "STEP", '
                     'got %s', event_type)
     if not event.build_event.HasField('step_number'):
@@ skipping 69 matching lines @@
 
   return event_wrapper
 
 
 def send_build_event(event_type,
                      hostname,
                      build_name,
                      build_number=None,
                      build_scheduling_time=None,
                      step_name=None,
+                     step_text=None,
                      step_number=None,
                      result=None,
                      extra_result_code=None,
                      timestamp_kind=None,
                      event_timestamp=None,
                      goma_stats=None,
                      goma_error=None,
                      goma_crash_report_id=None,
                      patch_url=None):
   """Send a ChromeInfraEvent filled with a BuildEvent
 
   Args:
     event_type (string): any name of enum BuildEvent.BuildEventType.
       (listed in infra_libs.event_mon.monitoring.BUILD_EVENT_TYPES)
     hostname (string): fqdn of the machine that is running the build / step.
       aka the bot name.
     build_name (string): name of the builder.
 
   Keyword args:
     build_number (int): as the name says.
     build_scheduling_time (int): timestamp telling when the build was
       scheduled. This is required when build_number is provided to make it
       possibly to distinguish two builds with the same build number.
     step_name (str): name of the step.
+    step_text (str): text of the step.
     step_number (int): rank of the step in the build. This is mandatory
       if step_name is provided, because step_name is not enough to tell the
       order.
     result (string): any name of enum BuildEvent.BuildResult.
       (listed in infra_libs.event_mon.monitoring.BUILD_RESULTS)
     extra_result_code (string or list of): arbitrary strings intended to provide
       more fine-grained information about the result.
     goma_stats (goma_stats_pb2.GomaStats): statistics output by the Goma proxy.
     goma_error (string): goma error type defined as GomaErrorType.
     goma_crash_report_id (string): id of goma crash report.
     patch_url (string): URL of the patch that triggered build
 
   Returns:
     success (bool): False if some error happened.
   """
   return get_build_event(event_type,
                          hostname,
                          build_name,
                          build_number=build_number,
                          build_scheduling_time=build_scheduling_time,
                          step_name=step_name,
+                         step_text=step_text,
                          step_number=step_number,
                          result=result,
                          extra_result_code=extra_result_code,
                          timestamp_kind=timestamp_kind,
                          event_timestamp=event_timestamp,
                          goma_stats=goma_stats,
                          goma_error=goma_error,
                          goma_crash_report_id=goma_crash_report_id,
                          patch_url=patch_url).send()
 
 
 def send_events(events):
   """Send several events at once to the endpoint.
 
   Args:
     events (iterable of Event): events to send
 
   Return:
     success (bool): True if data was successfully received by the endpoint.
   """
   return config._router.push_event(tuple(e.log_event() for e in events))