164 for task in argumentsList[:initialTasks]: |
164 for task in argumentsList[:initialTasks]: |
165 taskQueue.put(task) |
165 taskQueue.put(task) |
166 |
166 |
167 # Start worker processes |
167 # Start worker processes |
168 for _ in range(NumberOfProcesses): |
168 for _ in range(NumberOfProcesses): |
169 multiprocessing.Process(target=worker, args=(taskQueue, doneQueue))\ |
169 multiprocessing.Process( |
170 .start() |
170 target=worker, args=(taskQueue, doneQueue) |
|
171 ).start() |
171 |
172 |
172 # Get and send results |
173 # Get and send results |
173 endIndex = len(argumentsList) - initialTasks |
174 endIndex = len(argumentsList) - initialTasks |
174 for i in range(len(argumentsList)): |
175 for i in range(len(argumentsList)): |
175 resultSent = False |
176 resultSent = False |
331 try: |
332 try: |
332 lineFlags += extractLineFlags(lines[lineno].strip(), |
333 lineFlags += extractLineFlags(lines[lineno].strip(), |
333 flagsLine=True) |
334 flagsLine=True) |
334 except IndexError: |
335 except IndexError: |
335 pass |
336 pass |
336 if "__IGNORE_WARNING__" not in lineFlags and \ |
337 if ( |
337 "noqa" not in lineFlags: |
338 "__IGNORE_WARNING__" not in lineFlags and |
|
339 "noqa" not in lineFlags |
|
340 ): |
338 results.append((_fn, lineno, col, "", message, msg_args)) |
341 results.append((_fn, lineno, col, "", message, msg_args)) |
339 except SyntaxError as err: |
342 except SyntaxError as err: |
340 if err.text.strip(): |
343 if err.text.strip(): |
341 msg = err.text.strip() |
344 msg = err.text.strip() |
342 else: |
345 else: |