diff --git a/scrapy/trunk/scrapy/core/engine.py b/scrapy/trunk/scrapy/core/engine.py index 697f3772c..c1cff3c53 100644 --- a/scrapy/trunk/scrapy/core/engine.py +++ b/scrapy/trunk/scrapy/core/engine.py @@ -17,7 +17,7 @@ from scrapy.core.downloader import Downloader from scrapy.core.exceptions import IgnoreRequest, HttpException, DontCloseDomain from scrapy.http import Response, Request from scrapy.item import ScrapedItem -from scrapy.item.pipeline import ItemPipeline +from scrapy.item.pipeline import ItemPipelineManager from scrapy.spider import spiders from scrapy.spider.middleware import SpiderMiddlewareManager from scrapy.utils.defer import chain_deferred, defer_succeed, mustbe_deferred, deferred_degenerate @@ -59,7 +59,7 @@ class ExecutionEngine(object): self.downloader = downloader or Downloader() self.spidermiddleware = SpiderMiddlewareManager() self._scraping = {} - self.pipeline = ItemPipeline() + self.pipeline = ItemPipelineManager() # key dictionary of per domain lists of initial requests to scrape self.starters = {} diff --git a/scrapy/trunk/scrapy/item/pipeline.py b/scrapy/trunk/scrapy/item/pipeline.py index 5adc0555e..98692358b 100644 --- a/scrapy/trunk/scrapy/item/pipeline.py +++ b/scrapy/trunk/scrapy/item/pipeline.py @@ -5,7 +5,7 @@ from scrapy.utils.misc import load_class from scrapy.utils.defer import defer_succeed, mustbe_deferred from scrapy.conf import settings -class ItemPipeline(object): +class ItemPipelineManager(object): def __init__(self): self.loaded = False