[Predator] Run predator.

appengine/findit/util_scripts/crash_queries/delta_test/run-delta-test.py

 # 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.
 
 """Runs delta test on 2 findit versions."""
 
 import argparse
 from datetime import date
 from datetime import timedelta
-import pickle
 import logging
 import os
+import pickle
 import sys
 
 _SCRIPT_DIR = os.path.join(os.path.dirname(__file__), os.path.pardir,
                            os.path.pardir)
 sys.path.insert(1, _SCRIPT_DIR)
 
 import script_util
 script_util.SetUpSystemPaths()
 
-from crash.type_enums import CrashClient
 from crash_queries.delta_test import delta_test
 from crash_queries.delta_test import delta_util
 
 _TODAY = date.today().strftime('%Y-%m-%d')
 _A_YEAR_AGO = (date.today() - timedelta(days=365)).strftime('%Y-%m-%d')
 
 # App Engine APIs will fail if batch size is more than 1000.
 _MAX_BATCH_SIZE = 1000
 _DEFAULT_BATCH_SIZE = _MAX_BATCH_SIZE
 
@@ skipping 85 matching lines @@
 
   # If only one revision provided, default the rev2 to HEAD.
   if len(args.revisions) == 1:
     args.revisions.append('HEAD')
 
   git_hash1 = delta_util.ParseGitHash(args.revisions[0])
   git_hash2 = delta_util.ParseGitHash(args.revisions[1])
 
   delta_result_prefix = '%s_%s_%s..%s.delta' % (git_hash1[:7], git_hash2[:7],
                                                 args.since, args.until)
-  delta_csv_path = os.path.join(
-      DELTA_RESULTS_DIRECTORY, '%s.csv' % delta_result_prefix)
-  delta_path = os.path.join(
-      DELTA_RESULTS_DIRECTORY, '.%s' % delta_result_prefix)
+  delta_csv_path = os.path.join(DELTA_RESULTS_DIRECTORY,
+                                '%s.csv' % delta_result_prefix)
+  delta_path = os.path.join(DELTA_RESULTS_DIRECTORY,
+                            delta_result_prefix)
 
   # Check if delta results already existed.
   if os.path.exists(delta_csv_path):
-    logging.info('Delta results existed in\n%s', delta_csv_path)
+    print 'Delta results existed in\n%s' % delta_csv_path
     if not os.path.exists(delta_path):
-      logging.info('Cannot print out delta results, '
-                   'please open %s to see the results.')
+      print 'Cannot print out delta results, please open %s to see the results.'
       return
 
     with open(delta_path) as f:
       deltas, crash_num = pickle.load(f)
   else:
-    logging.info('Running delta test...')
+    print 'Running delta test...'
     # Get delta of results between git_hash1 and git_hash2.
     deltas, crash_num = delta_test.DeltaEvaluator(
         git_hash1, git_hash2, args.client, args.app,
         start_date=args.since, end_date=args.until,
         batch_size=args.batch, verbose=args.verbose)
     delta_util.FlushResult([deltas, crash_num], delta_path)
-    delta_util.WriteDeltaToCSV(deltas, crash_num,
+    delta_util.WriteDeltaToCSV(deltas, crash_num, args.app,
                                git_hash1, git_hash2, delta_csv_path)
 
   # Print delta results to users.
-  logging.info('\n========================= Summary =========================')
-  delta_util.PrintDelta(deltas, crash_num)
+  print '\n========================= Summary ========================='
+  delta_util.PrintDelta(deltas, crash_num, args.app)
 
 
 if __name__ == '__main__':
   RunDeltaTest()