From 5b4d9f8f85f0b145a15e83e4dd4d9d2886ab9bff Mon Sep 17 00:00:00 2001 From: olveyra Date: Fri, 8 Aug 2008 17:16:27 +0000 Subject: [PATCH] fix --HG-- extra : convert_revision : svn%3Ab85faa78-f9eb-468e-a121-7cced6da292c%40154 --- scrapy/trunk/scrapy/contrib/pbcluster/worker/manager.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/scrapy/trunk/scrapy/contrib/pbcluster/worker/manager.py b/scrapy/trunk/scrapy/contrib/pbcluster/worker/manager.py index c3d2f7502..e5d3255a9 100644 --- a/scrapy/trunk/scrapy/contrib/pbcluster/worker/manager.py +++ b/scrapy/trunk/scrapy/contrib/pbcluster/worker/manager.py @@ -89,7 +89,9 @@ class ClusterWorker(pb.Root): proc = self.running[domain] log.msg("ClusterWorker: Sending shutdown signal to domain=%s, pid=%d" % (domain, proc.pid)) d = self.crawler["domain"].callRemote("stop") - d.addCallbacks(callback=lambda x: proc.status="closing", errback=lambda reason: log.msg(reason, log.ERROR)) + def _close(): + proc.status = "closing" + d.addCallbacks(callback=_close, errback=lambda reason: log.msg(reason, log.ERROR)) return self.status(0, "Stopped process %s" % proc) else: return self.status(1, "%s: domain not running." % domain)