Update appengine-pipelines before files API turndown.

appengine/findit/waterfall/extract_signal_pipeline.py

 # 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.
 
 import base64
 import cStringIO
 import logging
 import json
 
 from google.appengine.api.urlfetch import ResponseTooLargeError
 
-from pipeline_utils.appengine_third_party_pipeline_src_pipeline import pipeline
+from pipeline_utils.appengine_third_party_pipeline_python_src_pipeline \
+    import pipeline
 
 from common.http_client_appengine import HttpClientAppengine as HttpClient
 from model.wf_step import WfStep
 from waterfall import buildbot
 from waterfall import extractors
 from waterfall import lock_util
 from waterfall.base_pipeline import BasePipeline
 
 
 class ExtractSignalPipeline(BasePipeline):
@@ skipping 131 matching lines @@
         try:
           step.put()
         except Exception as e:  # pragma: no cover
           # Sometimes, the step log is too large to save in datastore.
           logging.exception(e)
 
       # TODO: save result in datastore?
       signals[step_name] = extractors.ExtractSignal(
           master_name, builder_name, step_name, None, failure_log).ToDict()
     return signals