119 @return flag indicating to ignore the code |
119 @return flag indicating to ignore the code |
120 @rtype bool |
120 @rtype bool |
121 """ |
121 """ |
122 if lineFlags: |
122 if lineFlags: |
123 |
123 |
124 if "__IGNORE_WARNING__" in lineFlags or \ |
124 if ( |
125 "noqa" in lineFlags: |
125 "__IGNORE_WARNING__" in lineFlags or |
|
126 "noqa" in lineFlags |
|
127 ): |
126 # ignore all warning codes |
128 # ignore all warning codes |
127 return True |
129 return True |
128 |
130 |
129 for flag in lineFlags: |
131 for flag in lineFlags: |
130 # check individual warning code |
132 # check individual warning code |
195 for task in argumentsList[:initialTasks]: |
197 for task in argumentsList[:initialTasks]: |
196 taskQueue.put(task) |
198 taskQueue.put(task) |
197 |
199 |
198 # Start worker processes |
200 # Start worker processes |
199 for _ in range(NumberOfProcesses): |
201 for _ in range(NumberOfProcesses): |
200 multiprocessing.Process(target=worker, args=(taskQueue, doneQueue))\ |
202 multiprocessing.Process( |
201 .start() |
203 target=worker, args=(taskQueue, doneQueue) |
|
204 ).start() |
202 |
205 |
203 # Get and send results |
206 # Get and send results |
204 endIndex = len(argumentsList) - initialTasks |
207 endIndex = len(argumentsList) - initialTasks |
205 for i in range(len(argumentsList)): |
208 for i in range(len(argumentsList)): |
206 resultSent = False |
209 resultSent = False |