[Predator] Run predator.

appengine/findit/util_scripts/crash_queries/delta_test/delta_util.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.
 
 """Util functions for git repository processing."""
 
 import base64
 import hashlib
 import json
 import logging
@@ skipping 44 matching lines @@
 # TODO(crbug.com/662540): Add unittests.
 def EnsureDirExists(path):  # pragma: no cover
   directory = os.path.dirname(path)
   if os.path.exists(directory):
     return
 
   os.makedirs(directory)
 
 
 # TODO(crbug.com/662540): Add unittests.
-def FlushResult(result, result_path):  # pragma: no cover
+def FlushResult(result, result_path, serializer=pickle):  # pragma: no cover
   logging.info('\nFlushing results to %s', result_path)
   EnsureDirExists(result_path)
   with open(result_path, 'wb') as f:
-    pickle.dump(result, f)
+    serializer.dump(result, f)
 
 
 # TODO(crbug.com/662540): Add unittests.
 def PrintDelta(deltas, crash_num):  # pragma: no cover
   logging.info(('\n+++++++++++++++++++++'
                 '\nDelta on %d crashes '
                 '\n+++++++++++++++++++++'), crash_num)
 
   if not deltas:
     logging.info('Two sets of results are the same.')
@@ skipping 20 matching lines @@
     for crash_id, delta in deltas.iteritems():
       delta_str_dict = delta.delta_str_dict
       feedback_url = _FEEDBACK_URL_TEMPLATE % crash_id
       f.write('%s, "%s", "%s", "%s", "%s"\n' % (
           feedback_url,
           _EncodeStr(delta_str_dict.get('project', '')),
           _EncodeStr(delta_str_dict.get('components', '')),
           _EncodeStr(delta_str_dict.get('cls', '')),
           _EncodeStr(delta_str_dict.get('regression_range', ''))
       ))