Use logdog butler subcommand to run tests.

build/android/test_wrapper/logdog_wrapper.py

 #!/usr/bin/env python
 # Copyright 2016 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.
 
 """Wrapper for adding logdog streaming support to swarming tasks."""
 
 import argparse
 import logging
 import os
@@ skipping 36 matching lines @@
 
   return handler
 
 
 def main():
   parser = CommandParser()
   args, test_cmd = parser.parse_known_args(sys.argv[1:])
   logging.basicConfig(level=logging.INFO)
   if not test_cmd:
     parser.error('Must specify command to run after the logdog flags')
-  test_proc = subprocess.Popen(test_cmd)
-  original_sigterm_handler = signal.signal(
-      signal.SIGTERM, CreateSignalForwarder(test_proc))
-  try:
-    result = test_proc.wait()
-  finally:
-    signal.signal(signal.SIGTERM, original_sigterm_handler)
+
   if '${SWARMING_TASK_ID}' in args.prefix:
     args.prefix = args.prefix.replace('${SWARMING_TASK_ID}',
                                       os.environ.get('SWARMING_TASK_ID'))
   url = CreateUrl('luci-logdog.appspot.com', args.project, args.prefix,
                   args.name)
+
   logdog_cmd = [args.logdog_bin_cmd, '-project', args.project,
                 '-output', 'logdog,host=%s' % args.logdog_server,
                 '-prefix', args.prefix,
                 '-service-account-json', args.service_account_json,
                 'stream', '-source', args.source,
                 '-stream', '-name=%s' % args.name]
 
   if not os.path.exists(args.logdog_bin_cmd):
+    test_proc = subprocess.Popen(test_cmd)

[jbudorick, 2017/02/14 23:50:27]

Why is this moving? We still need to pass signals into the process...

+    original_sigterm_handler = signal.signal(
+      signal.SIGTERM, CreateSignalForwarder(test_proc))
+    try:
+      result = test_proc.wait()
+    finally:
+      signal.signal(signal.SIGTERM, original_sigterm_handler)
+
     logging.error(
         'Logdog binary %s unavailable. Unable to upload logcats.',
         args.logdog_bin_cmd)
-  elif not os.path.exists(args.source):
+    return result
+
+  test_cmd = [args.logdog_bin_cmd, '-project', args.project,
+                '-output', 'logdog,host=%s' % args.logdog_server,
+                '-prefix', args.prefix,
+                '-service-account-json', args.service_account_json,
+                'run', '--'] + test_cmd
+  result = subprocess.call(test_cmd)
+
+  if not os.path.exists(args.source):
     logging.error(
         'Logcat sources not found at %s. Unable to upload logcats.',
         args.source)
   else:
     subprocess.call(logdog_cmd)
     logging.info('Logcats are located at: %s', url)
   return result
 
 
 if __name__ == '__main__':
   sys.exit(main())