From 8b8e3e75322f6e60746df4585f1071fc611a14d6 Mon Sep 17 00:00:00 2001 From: olveyra Date: Wed, 23 Jul 2008 19:23:47 +0000 Subject: [PATCH] fixed a bug in which pending list remains stalled because not proper clean out of loading list --HG-- extra : convert_revision : svn%3Ab85faa78-f9eb-468e-a121-7cced6da292c%40101 --- scrapy/trunk/scrapy/contrib/pbcluster/master/manager.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/scrapy/trunk/scrapy/contrib/pbcluster/master/manager.py b/scrapy/trunk/scrapy/contrib/pbcluster/master/manager.py index 33c5af9c8..a03de4abc 100644 --- a/scrapy/trunk/scrapy/contrib/pbcluster/master/manager.py +++ b/scrapy/trunk/scrapy/contrib/pbcluster/master/manager.py @@ -119,11 +119,13 @@ class Node(pb.Referenceable): if status['callresponse'][0] == 1: #slots are complete. Reschedule in master with priority reduced by one. #self.master.loading check should avoid this to happen + self.master.loading.remove(pending['domain']) self.master.schedule([pending['domain']], pending['settings'], pending['priority'] - 1) log.msg("Domain %s rescheduled: no proc space in node." % pending['domain'], log.WARNING) elif status['callresponse'][0] == 2: #domain already running in node. Reschedule with same priority. #self.master.loading check should avoid this to happen + self.master.loading.remove(pending['domain']) self.master.schedule([pending['domain']], pending['settings'], pending['priority']) log.msg("Domain %s rescheduled: already running in node." % pending['domain'], log.WARNING)