From 215151dd8628839b53534bf4bd76ba0bfdadebcf Mon Sep 17 00:00:00 2001 From: Pablo Hoffman Date: Thu, 23 Oct 2008 12:41:49 +0000 Subject: [PATCH] improved worker error logging for communication with master --HG-- extra : convert_revision : svn%3Ab85faa78-f9eb-468e-a121-7cced6da292c%40336 --- .../scrapy/contrib/pbcluster/worker/manager.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/scrapy/branches/cluster-refactor/scrapy/contrib/pbcluster/worker/manager.py b/scrapy/branches/cluster-refactor/scrapy/contrib/pbcluster/worker/manager.py index 4dc220170..901721e32 100644 --- a/scrapy/branches/cluster-refactor/scrapy/contrib/pbcluster/worker/manager.py +++ b/scrapy/branches/cluster-refactor/scrapy/contrib/pbcluster/worker/manager.py @@ -140,7 +140,9 @@ class ClusterWorker(pb.Root): self._master = None log.msg("Lost connection to master", log.ERROR) else: - deferred.addCallbacks(callback=lambda x: x, errback=lambda reason: log.msg(reason, log.ERROR)) + def _eb(failure): + log.msg("Error received from ClusterMaster\n%s" % failure, level=log.ERROR) + deferred.addErrback(_eb) def remote_set_master(self, master): """Set the master for this worker"""