pre-commit/flake8
1
0
Fork 0
mirror of https://github.com/PyCQA/flake8.git synced 2026-04-11 15:24:18 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Add a results queue

Browse source
This commit is contained in:
Ian Cordasco 2016-03-15 08:40:43 -05:00
parent 07b9ffbeb9
commit 3b830366b6
1 changed files with 2 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

2
flake8/checker.py
View file

@ -55,6 +55,7 @@ class Manager(object):
self.checks = checker_plugins self.checks = checker_plugins
self.jobs = self._job_count() self.jobs = self._job_count()
self.process_queue = None self.process_queue = None
self.results_queue = None
self.using_multiprocessing = False self.using_multiprocessing = False
self.processes = [] self.processes = []
self.checkers = [] self.checkers = []
@ -62,6 +63,7 @@ class Manager(object):
if self.jobs is not None and self.jobs > 1: if self.jobs is not None and self.jobs > 1:
self.using_multiprocessing = True self.using_multiprocessing = True
self.process_queue = multiprocessing.Queue() self.process_queue = multiprocessing.Queue()
self.results_queue = multiprocessing.Queue()
def _job_count(self): def _job_count(self):
# type: () -> Union[int, NoneType] # type: () -> Union[int, NoneType]