From 3ed8837a3ee408a02e84ff6e094e50ae7f8cfbbe Mon Sep 17 00:00:00 2001 From: Ben Kurtovic Date: Sun, 31 Aug 2014 17:54:15 -0500 Subject: [PATCH] Fix stopping queues in local mode. --- earwigbot/wiki/copyvios/workers.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/earwigbot/wiki/copyvios/workers.py b/earwigbot/wiki/copyvios/workers.py index de33b82..8a5eec0 100644 --- a/earwigbot/wiki/copyvios/workers.py +++ b/earwigbot/wiki/copyvios/workers.py @@ -219,7 +219,7 @@ class _CopyvioWorker(object): if not self._queue: self._acquire_new_site() - logmsg = u"Fetching a new source URL from site queue {0}" + logmsg = u"Fetching source URL from queue {0}" self._logger.debug(logmsg.format(self._site)) self._queues.lock.acquire() try: @@ -371,6 +371,9 @@ class CopyvioWorkspace(object): for source in self.sources: self._logger.debug("Waiting on source: {0}".format(source.url)) source.join(self._until) + if not _is_globalized: + for i in xrange(len(self._workers)): + self._queues.unassigned.put((StopIteration, None)) self._logger.debug("Done waiting") def compare(self, source, source_chain):