Add infra_libs as a bootstrap dependency.

appengine/chromium_try_flakes/status/cq_status.py

 # Copyright 2014 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.
 
 import datetime
 import dateutil.parser
 import logging
 import json
 import time
 import urllib2
 
 import gae_ts_mon
 from google.appengine.api import taskqueue
 from google.appengine.api import urlfetch
 from google.appengine.ext import deferred
 from google.appengine.ext import ndb
 from google.appengine.runtime import DeadlineExceededError
 from handlers.flake_issues import MIN_REQUIRED_FLAKY_RUNS
 from model.build_run import BuildRun
 from model.build_run import PatchsetBuilderRuns
 from model.fetch_status import FetchStatus
 from model.flake import Flake
 from model.flake import FlakeOccurrence
 from model.flake import FlakyRun
 from status import build_result, util
-import time_functions.timestamp
+from infra_libs.time_functions import timestamp as tf_timestamp

[Sergiy Byelozyorov, 2016/08/04 21:16:53]

please change this to

import infra_libs.time_functions.timestamp

and just add infra_libs. prefix to calls below

 
 
 requests_metric = gae_ts_mon.CounterMetric(
     'flakiness_pipeline/cq_status/requests',
     description='Requests made to the chromium-cq-status API')
 flakes_metric = gae_ts_mon.CounterMetric(
     'flakiness_pipeline/flake_occurrences_detected',
     description='Detected flake occurrences')
 occurrences_per_flake_day = gae_ts_mon.NonCumulativeDistributionMetric(
     'flakiness_pipeline/occurrences_per_flake/day',
@@ skipping 289 matching lines @@
   fetch_status = FetchStatus.query().get()
   cursor = ''
   begin = ''
   end = ''
   retry_count = 0
 
   while True:
     if fetch_status:
       if fetch_status.done:
         logging.info('historical fetching done so fetch latest...')
-        end = str(time_functions.timestamp.utcnow_ts())
+        end = str(tf_timestamp.utcnow_ts())
 
         last_build_run_seen = BuildRun.query().order(
             -BuildRun.time_finished).fetch(1)
-        begin = str(time_functions.timestamp.utctimestamp(
+        begin = str(tf_timestamp.utctimestamp(
             last_build_run_seen[0].time_finished))
         cursor = ''
       else:
         begin = fetch_status.begin
         end = fetch_status.end
         cursor = fetch_status.cursor
     else:
       logging.info('didnt find any historical information. fetching last week')
-      begin = str(time_functions.timestamp.utctimestamp(
+      begin = str(tf_timestamp.utctimestamp(
           datetime.datetime.utcnow() - datetime.timedelta(weeks=1)))
-      end = str(time_functions.timestamp.utcnow_ts())
+      end = str(tf_timestamp.utcnow_ts())
 
     if begin and end:
       logging.info(
           'fetching from %s to %s cursor: %s',
           str(datetime.datetime.utcfromtimestamp(float(begin))),
           str(datetime.datetime.utcfromtimestamp(float(end))),
           cursor)
     else:
       logging.info('fetching with no begin/end and cursor: ' + cursor)
 
@@ skipping 73 matching lines @@
         fetch_status.begin = begin
         fetch_status.end = end
         fetch_status.cursor = cursor
       fetch_status.put()
 
       if not more:
         return  # finish the cron job and wait for next iteration
     except urllib2.URLError, e:
       requests_metric.increment_by(1, fields={'status': 'fetch_error'})
       logging.warning('Failed to fetch CQ status: %s', e.reason)