Revision b459a848 lib/workerpool.py
b/lib/workerpool.py | ||
---|---|---|
59 | 59 |
Users of a worker pool must override RunTask in a subclass. |
60 | 60 |
|
61 | 61 |
""" |
62 |
# pylint: disable-msg=W0212
|
|
62 |
# pylint: disable=W0212 |
|
63 | 63 |
def __init__(self, pool, worker_id): |
64 | 64 |
"""Constructor for BaseWorker thread. |
65 | 65 |
|
... | ... | |
169 | 169 |
logging.debug("Starting task %r, priority %s", args, priority) |
170 | 170 |
assert self.getName() == self._worker_id |
171 | 171 |
try: |
172 |
self.RunTask(*args) # pylint: disable-msg=W0142
|
|
172 |
self.RunTask(*args) # pylint: disable=W0142 |
|
173 | 173 |
finally: |
174 | 174 |
self.SetTaskName(None) |
175 | 175 |
logging.debug("Done with task %r, priority %s", args, priority) |
... | ... | |
184 | 184 |
args, defer.priority) |
185 | 185 |
|
186 | 186 |
assert self._HasRunningTaskUnlocked() |
187 |
except: # pylint: disable-msg=W0702
|
|
187 |
except: # pylint: disable=W0702 |
|
188 | 188 |
logging.exception("Caught unhandled exception") |
189 | 189 |
|
190 | 190 |
assert self._HasRunningTaskUnlocked() |
... | ... | |
384 | 384 |
|
385 | 385 |
""" |
386 | 386 |
for worker in self._workers + self._termworkers: |
387 |
if worker._HasRunningTaskUnlocked(): # pylint: disable-msg=W0212
|
|
387 |
if worker._HasRunningTaskUnlocked(): # pylint: disable=W0212 |
|
388 | 388 |
return True |
389 | 389 |
return False |
390 | 390 |
|
Also available in: Unified diff