From 3b830366b6c96ec65071eb316d69dee463d91390 Mon Sep 17 00:00:00 2001 From: Ian Cordasco Date: Tue, 15 Mar 2016 08:40:43 -0500 Subject: [PATCH] Add a results queue --- flake8/checker.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/flake8/checker.py b/flake8/checker.py index 0398187..274dc23 100644 --- a/flake8/checker.py +++ b/flake8/checker.py @@ -55,6 +55,7 @@ class Manager(object): self.checks = checker_plugins self.jobs = self._job_count() self.process_queue = None + self.results_queue = None self.using_multiprocessing = False self.processes = [] self.checkers = [] @@ -62,6 +63,7 @@ class Manager(object): if self.jobs is not None and self.jobs > 1: self.using_multiprocessing = True self.process_queue = multiprocessing.Queue() + self.results_queue = multiprocessing.Queue() def _job_count(self): # type: () -> Union[int, NoneType]