Revision 7260cfbe lib/workerpool.py
b/lib/workerpool.py | ||
---|---|---|
34 | 34 |
Users of a worker pool must override RunTask in a subclass. |
35 | 35 |
|
36 | 36 |
""" |
37 |
# pylint: disable-msg=W0212 |
|
37 | 38 |
def __init__(self, pool, worker_id): |
38 | 39 |
"""Constructor for BaseWorker thread. |
39 | 40 |
|
... | ... | |
118 | 119 |
self.RunTask(*self._current_task) |
119 | 120 |
logging.debug("Worker %s: done with task %r", |
120 | 121 |
self.worker_id, self._current_task) |
121 |
except: |
|
122 |
except: # pylint: disable-msg=W0702
|
|
122 | 123 |
logging.error("Worker %s: Caught unhandled exception", |
123 | 124 |
self.worker_id, exc_info=True) |
124 | 125 |
finally: |
... | ... | |
223 | 224 |
|
224 | 225 |
""" |
225 | 226 |
for worker in self._workers + self._termworkers: |
226 |
if worker._HasRunningTaskUnlocked(): |
|
227 |
if worker._HasRunningTaskUnlocked(): # pylint: disable-msg=W0212
|
|
227 | 228 |
return True |
228 | 229 |
return False |
229 | 230 |
|
Also available in: Unified diff