From 669b98c4fc107960ee98ecbfe61c5cab10867810 Mon Sep 17 00:00:00 2001 From: Pablo Hoffman Date: Wed, 24 Aug 2011 11:26:35 -0300 Subject: [PATCH] pass close reason to close() method of new DupeFilter --- scrapy/core/scheduler.py | 2 +- scrapy/dupefilter.py | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/scrapy/core/scheduler.py b/scrapy/core/scheduler.py index ba3dccc4e..9dc7be5c2 100644 --- a/scrapy/core/scheduler.py +++ b/scrapy/core/scheduler.py @@ -39,7 +39,7 @@ class Scheduler(object): prios = self.dqs.close() with open(join(self.dqdir, 'active.json'), 'w') as f: json.dump(prios, f) - return self.df.close() + return self.df.close(reason) def enqueue_request(self, request): if not request.dont_filter and self.df.request_seen(request): diff --git a/scrapy/dupefilter.py b/scrapy/dupefilter.py index 69d95b181..94dc88ba9 100644 --- a/scrapy/dupefilter.py +++ b/scrapy/dupefilter.py @@ -15,7 +15,7 @@ class BaseDupeFilter(object): def open(self): # can return deferred pass - def close(self): # can return a deferred + def close(self, reason): # can return a deferred pass @@ -41,6 +41,6 @@ class RFPDupeFilter(BaseDupeFilter): if self.file: self.file.write(fp + os.linesep) - def close(self): + def close(self, reason): if self.file: self.file.close()