pre-commit/flake8
1
0
Fork 0
mirror of https://github.com/PyCQA/flake8.git synced 2026-04-10 14:54:17 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merged in flox/flake8/mp-win32 (pull request #45)

Browse source 
Allow to configure multiple jobs on Windows; issues #153 and #154. Closes #153, #154, #156
This commit is contained in:
Ian Cordasco 2014-07-02 09:46:14 -05:00
commit 88f9059782
1 changed files with 10 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

10
flake8/reporter.py
View file

@ -2,6 +2,7 @@
# Adapted from a contribution of Johan Dahlin # Adapted from a contribution of Johan Dahlin
import collections import collections
import sys
try: try:
import multiprocessing import multiprocessing
except ImportError: # Python 2.5 except ImportError: # Python 2.5
@ -14,6 +15,7 @@ __all__ = ['multiprocessing', 'BaseQReport', 'QueueReport']
class BaseQReport(pep8.BaseReport): class BaseQReport(pep8.BaseReport):
"""Base Queue Report.""" """Base Queue Report."""
_loaded = False # Windows support
def __init__(self, options): def __init__(self, options):
assert options.jobs > 0 assert options.jobs > 0
@ -24,9 +26,13 @@ class BaseQReport(pep8.BaseReport):
# init queues # init queues
self.task_queue = multiprocessing.Queue() self.task_queue = multiprocessing.Queue()
self.result_queue = multiprocessing.Queue() self.result_queue = multiprocessing.Queue()
if sys.platform == 'win32':
# Work around http://bugs.python.org/issue10845
sys.modules['__main__'].__file__ = __file__
def start(self): def start(self):
super(BaseQReport, self).start() super(BaseQReport, self).start()
self.__class__._loaded = True
# spawn processes # spawn processes
for i in range(self.n_jobs): for i in range(self.n_jobs):
p = multiprocessing.Process(target=self.process_main) p = multiprocessing.Process(target=self.process_main)
@ -40,6 +46,10 @@ class BaseQReport(pep8.BaseReport):
super(BaseQReport, self).stop() super(BaseQReport, self).stop()
def process_main(self): def process_main(self):
if not self._loaded:
# Windows needs to parse again the configuration
from flake8.main import get_style_guide, DEFAULT_CONFIG
get_style_guide(parse_argv=True, config_file=DEFAULT_CONFIG)
for filename in iter(self.task_queue.get, 'DONE'): for filename in iter(self.task_queue.get, 'DONE'):
self.input_file(filename) self.input_file(filename)
self.result_queue.put(self.get_state()) self.result_queue.put(self.get_state())