[Culprit-Finder] Seperate gae related part in cache_decorator and gitile repository to gae_libs/

appengine/findit/crash/crash_pipeline.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.
 
 import copy
 import json
 import logging
 
 from crash import monitoring
 
 from common import appengine_util
 from common import pubsub_util
 from common.http_client_appengine import HttpClientAppengine
 from common.pipeline_wrapper import BasePipeline
 from common.pipeline_wrapper import pipeline
 from crash import findit_for_chromecrash
 from crash import findit_for_clusterfuzz
 from crash.type_enums import CrashClient
 from lib import time_util
-from lib.gitiles import gitiles_repository
+from gae_libs.gitiles import cached_gitiles_repository
 from model import analysis_status
 
 
 # TODO(http://crbug.com/659346): write complete coverage tests for this.
 def FinditForClientID(client_id, repository): # pragma: no cover
   """Construct a Findit object from a client id string specifying the class.
 
   We cannot pass Findit objects to the various methods in
   ``crash.crash_pipeline``, because they are not JSON serializable. For
   now, we just serialize Findit objects as their ``client_id``, and then
@@ skipping 55 matching lines @@
 # processes, so we'll actually end up reconstructing the ``Findit`` object
 # twice. This also means ``run`` can't store anything in the pipeline
 # object and expect it to still be available in the ``finalized`` method.
 
 class CrashBasePipeline(BasePipeline):
   def __init__(self, client_id, crash_identifiers):
     super(CrashBasePipeline, self).__init__(client_id, crash_identifiers)
     self._crash_identifiers = crash_identifiers
     self._findit = FinditForClientID(
         client_id,
-        gitiles_repository.GitilesRepository(HttpClientAppengine()))
+        cached_gitiles_repository.CachedGitilesRepository(
+            HttpClientAppengine()))
 
   @property
   def client_id(self): # pragma: no cover
     return self._findit.client_id
 
   def run(self, *args, **kwargs):
     raise NotImplementedError()
 
 
 class CrashAnalysisPipeline(CrashBasePipeline):
@@ skipping 122 matching lines @@
     N.B., due to the structure of AppEngine pipelines, this method must
     accept the same arguments as are passed to ``__init__``; however,
     because they were already passed to ``__init__`` there's no use in
     recieving them here. Thus, we discard all the arguments to this method
     (except for ``self``, naturally).
     """
     run_analysis = yield CrashAnalysisPipeline(
         self._client_id, self._crash_identifiers)
     with pipeline.After(run_analysis):
       yield PublishResultPipeline(self._client_id, self._crash_identifiers)