Revision 7260cfbe lib/jqueue.py
b/lib/jqueue.py | ||
---|---|---|
154 | 154 |
@ivar change: a Condition variable we use for waiting for job changes |
155 | 155 |
|
156 | 156 |
""" |
157 |
# pylint: disable-msg=W0212 |
|
157 | 158 |
__slots__ = ["queue", "id", "ops", "log_serial", |
158 | 159 |
"received_timestamp", "start_timestamp", "end_timestamp", |
159 | 160 |
"lock_status", "change", |
... | ... | |
419 | 420 |
"""The actual job workers. |
420 | 421 |
|
421 | 422 |
""" |
422 |
def RunTask(self, job): |
|
423 |
def RunTask(self, job): # pylint: disable-msg=W0221
|
|
423 | 424 |
"""Job executor. |
424 | 425 |
|
425 | 426 |
This functions processes a job. It is closely tied to the _QueuedJob and |
... | ... | |
559 | 560 |
|
560 | 561 |
""" |
561 | 562 |
def wrapper(self, *args, **kwargs): |
563 |
# pylint: disable-msg=W0212 |
|
562 | 564 |
assert self._queue_lock is not None, "Queue should be open" |
563 | 565 |
return fn(self, *args, **kwargs) |
564 | 566 |
return wrapper |
... | ... | |
963 | 965 |
|
964 | 966 |
try: |
965 | 967 |
job = _QueuedJob.Restore(self, data) |
966 |
except Exception, err: |
|
968 |
except Exception, err: # pylint: disable-msg=W0703
|
|
967 | 969 |
new_path = self._GetArchivedJobPath(job_id) |
968 | 970 |
if filepath == new_path: |
969 | 971 |
# job already archived (future case) |
Also available in: Unified diff