Index: gclient_utils.py |
diff --git a/gclient_utils.py b/gclient_utils.py |
index 924f0a57df5060be7a3b6b720856755859086563..9c7274bc86b40a32f682074d33e540c6f2898d08 100644 |
--- a/gclient_utils.py |
+++ b/gclient_utils.py |
@@ -549,8 +549,8 @@ class WorkItem(object): |
# A unique string representing this work item. |
name = None |
- def run(self, work_queue, options): |
- """work_queue and options are passed as keyword arguments so they should be |
+ def run(self, work_queue): |
+ """work_queue is passed as keyword argument so it should be |
the last parameters of the function when you override it.""" |
pass |
@@ -661,7 +661,7 @@ class ExecutionQueue(object): |
self.running.append(t) |
else: |
t.join() |
- t.kwargs['options'].stdout.full_flush() |
+ sys.stdout.full_flush() |
if self.progress: |
self.progress.update(1) |
assert not t.item.name in self.ran |
@@ -672,10 +672,7 @@ class ExecutionQueue(object): |
if self.jobs > 1: |
# Start the thread. |
index = len(self.ran) + len(self.running) + 1 |
- # Copy 'options'. |
- task_kwargs = kwargs.copy() |
- task_kwargs['options'] = copy.copy(task_kwargs['options']) |
- new_thread = self._Worker(task_item, index, args, task_kwargs) |
+ new_thread = self._Worker(task_item, index, args, kwargs) |
self.running.append(new_thread) |
new_thread.start() |
else: |