cq_stats: only take into account attempts within current date range

infra/tools/cq_stats/cq_stats.py

 #!/usr/bin/python
 # 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.
 '''Generate stats of CQ usage.'''
 
 import argparse
 import calendar
 import collections
 import datetime
@@ skipping 597 matching lines @@
   # Create map issue:patchset -> #attempts
   patches, issues = set(), set()
   for reason in results:
     issues.add(reason['fields']['issue'])
     patches.add((reason['fields']['issue'], reason['fields']['patchset']))
   stats['issue-count'] = len(issues)
   stats['patchset-count'] = len(patches)
   patch_stats = {}
   # Fetch and process each patchset log
   def get_patch_stats(patch_id):
-    return derive_patch_stats(end_date, patch_id)
+    return derive_patch_stats(begin_date, end_date, patch_id)
 
   if args.seq or not args.thread_pool:
     iterable = map(get_patch_stats, patches)
   else:
     pool = ThreadPool(min(args.thread_pool, len(patches)))
     iterable = pool.imap_unordered(get_patch_stats, patches)
   for patch_id, pstats in iterable:
     if not pstats['supported']:
       continue
     patch_stats[patch_id] = pstats
@@ skipping 32 matching lines @@
   msg_lines = message.splitlines()
   for line in msg_lines[1:]:
     words = line.split(None, 1)
     if not words:
       continue
     builder = words[0]
     builders.append(builder)
   return builders
 
 
-def derive_patch_stats(end_date, patch_id):
+def derive_patch_stats(begin_date, end_date, patch_id):
   """``patch_id`` is a tuple (issue, patchset)."""
-  results = fetch_cq_logs(end_date=end_date, filters=[
+  results = fetch_cq_logs(start_date=begin_date, end_date=end_date, filters=[
       'issue=%s' % patch_id[0], 'patchset=%s' % patch_id[1]])
   # The results should already ordered, but sort it again just to be sure.
   results = sorted(results, key=lambda r: r['timestamp'], reverse=True)
   logging.debug('derive_patch_stats(%r): fetched %d entries.',
                 patch_id, len(results))
   # Group by attempts
   attempts = []
 
   def new_attempt():
     attempt_empty = {
@@ skipping 510 matching lines @@
   logger = logging.getLogger()
   # TODO(sergeyberezin): how do I derive local timezone string?
   # Need to be able to pass dateutil.tz.tzlocal() directly.
   infra_libs.logs.process_argparse_options(args, logger)
   stats = acquire_stats(args)
   print_stats(args, stats)
 
 
 if __name__ == '__main__':
   sys.exit(main())