Upload basic info about completed swarming tasks to event_mon

appengine/swarming/test_env_handlers.py

 # coding: utf-8
 # 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.
 
 """Base class for handlers_*_test.py"""
 
 import base64
 import json
 import os
 
 import test_env
 test_env.setup_test_env()
 
 from protorpc.remote import protojson
 import webtest
 
+import event_mon_metrics
 import handlers_endpoints
 import swarming_rpcs
 from components import auth
 from components import auth_testing
 from components import stats_framework
 import gae_ts_mon
 from test_support import test_case
 
 from server import acl
 from server import large
 from server import stats
 
 
 class AppTestBase(test_case.TestCase):
   APP_DIR = test_env.APP_DIR
 
   def setUp(self):
     super(AppTestBase, self).setUp()
     self.bot_version = None
     self.source_ip = '192.168.2.2'
     self.testbed.init_user_stub()
 
     gae_ts_mon.reset_for_unittest(disable=True)
+    event_mon_metrics.initialize()
 
     # By default requests in tests are coming from bot with fake IP.
     # WSGI app that implements auth REST API.
     self.auth_app = webtest.TestApp(
         auth.create_wsgi_application(debug=True),
         extra_environ={
           'REMOTE_ADDR': self.source_ip,
           'SERVER_SOFTWARE': os.environ['SERVER_SOFTWARE'],
         })
 
@@ skipping 206 matching lines @@
 
   def client_create_task_raw(self, properties=None, **kwargs):
     """Creates a raw command TaskRequest via the Cloud Endpoints API."""
     properties = (properties or {}).copy()
     properties['command'] = ['python', 'run_test.py']
     return self._client_create_task(properties, **kwargs)
 
   def client_get_results(self, task_id):
     return self.endpoint_call(
         handlers_endpoints.SwarmingTaskService, 'result', {'task_id': task_id})