diff options
author | Yuheng Long <yuhenglong@google.com> | 2013-06-18 17:05:08 -0700 |
---|---|---|
committer | ChromeBot <chrome-bot@google.com> | 2013-06-18 20:31:34 -0700 |
commit | 5fe6dc81886f49eb2089c883c6862f2e896155cf (patch) | |
tree | 0ce636b5522fea2dbdc3e6146175a70481f9db34 /bestflags | |
parent | e610c1904b8fbdb4c14c67dede25aafc02167259 (diff) | |
download | toolchain-utils-5fe6dc81886f49eb2089c883c6862f2e896155cf.tar.gz |
Fixed the warnings from pylint.
BUG=None
TEST=None
Change-Id: I1b2b5df85eacb1b30557d108bf982054ea5e3cea
Reviewed-on: https://gerrit-int.chromium.org/39812
Reviewed-by: Luis Lozano <llozano@chromium.org>
Commit-Queue: Yuheng Long <yuhenglong@google.com>
Tested-by: Yuheng Long <yuhenglong@google.com>
Diffstat (limited to 'bestflags')
-rw-r--r-- | bestflags/pipeline_process.py | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/bestflags/pipeline_process.py b/bestflags/pipeline_process.py index 21d3c584..37f4a994 100644 --- a/bestflags/pipeline_process.py +++ b/bestflags/pipeline_process.py @@ -81,7 +81,7 @@ class PipelineProcess(multiprocessing.Process): """ # the worker pool - self._pool = multiprocessing.Pool(self._num_processes) + work_pool = multiprocessing.Pool(self._num_processes) # the helper process helper_process = multiprocessing.Process(target=self._helper, @@ -106,13 +106,13 @@ class PipelineProcess(multiprocessing.Process): self._helper_queue.put(task) else: # Let the workers do the actual work. - self._pool.apply_async(self._worker, args=(task, self._work_queue, + work_pool.apply_async(self._worker, args=(task, self._work_queue, self._result_queue)) mycache.append(task_key) # Shutdown the workers pool and the helper process. - self._pool.close() - self._pool.join() + work_pool.close() + work_pool.join() self._helper_queue.put(POISONPILL) helper_process.join() |