Index: appengine/findit/waterfall/extract_signal_pipeline.py |
diff --git a/appengine/findit/waterfall/extract_signal_pipeline.py b/appengine/findit/waterfall/extract_signal_pipeline.py |
index 2b553b668dda17ae29e21e6bd3f049d3c09193d5..7a03ddb9cc281f540c480d0b43260e4d092364ea 100644 |
--- a/appengine/findit/waterfall/extract_signal_pipeline.py |
+++ b/appengine/findit/waterfall/extract_signal_pipeline.py |
@@ -9,7 +9,8 @@ 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 |