r86539 MediaWiki - Code Review archive

Repository:MediaWiki
Revision:r86538‎ | r86539 | r86540 >
Date:19:59, 20 April 2011
Author:diederik
Status:deferred
Tags:
Comment:
Use multiprocessing for the transform phase as well.
Modified paths:
  • /trunk/tools/editor_trends/etl/transformer.py (modified) (history)

Diff [purge]

Index: trunk/tools/editor_trends/etl/transformer.py
@@ -39,9 +39,9 @@
4040
4141 def run(self):
4242 while True:
43 - new_editor = self.task_queue.get()
44 - self.task_queue.task_done()
45 - print '%s editors to go...' % messages.show(self.task_queue.qsize)
 43+ new_editor = self.tasks.get()
 44+ self.tasks.task_done()
 45+ print '%s editors to go...' % messages.show(self.tasks.qsize)
4646 if new_editor == None:
4747 break
4848 new_editor()