item pipeline: added check for domain not already closed

2009-06-15 18:59:40 -03:00 · 2009-06-15 18:59:40 -03:00 · 5e3ef5a2fd
parent aeb9734a80
commit 5e3ef5a2fd
1 changed files with 2 additions and 2 deletions
--- a/scrapy/item/pipeline.py
+++ b/scrapy/item/pipeline.py
@ -51,10 +51,10 @@ class ItemPipelineManager(object):

        This pipeline is configurable with the ITEM_PIPELINES setting
        """
-        if not self.pipeline:
+        domain = spider.domain_name
+        if not self.pipeline or domain not in self.domaininfo:
            return defer_succeed(item)

-        domain = spider.domain_name
        pipeline = self.pipeline[:]
        current_stage = pipeline[0]
        info = self.domaininfo[domain]