Revision 7e950d31 lib/jqueue.py
b/lib/jqueue.py | ||
---|---|---|
725 | 725 |
except KeyError: |
726 | 726 |
pass |
727 | 727 |
|
728 |
def _CheckRpcResult(self, result, nodes, failmsg): |
|
728 |
@staticmethod |
|
729 |
def _CheckRpcResult(result, nodes, failmsg): |
|
729 | 730 |
"""Verifies the status of an RPC call. |
730 | 731 |
|
731 | 732 |
Since we aim to keep consistency should this node (the current |
... | ... | |
806 | 807 |
result = rpc.RpcRunner.call_jobqueue_rename(names, addrs, rename) |
807 | 808 |
self._CheckRpcResult(result, self._nodes, "Renaming files (%r)" % rename) |
808 | 809 |
|
809 |
def _FormatJobID(self, job_id): |
|
810 |
@staticmethod |
|
811 |
def _FormatJobID(job_id): |
|
810 | 812 |
"""Convert a job ID to string format. |
811 | 813 |
|
812 | 814 |
Currently this just does C{str(job_id)} after performing some |
... | ... | |
1344 | 1346 |
|
1345 | 1347 |
return (archived_count, len(all_job_ids) - last_touched - 1) |
1346 | 1348 |
|
1347 |
def _GetJobInfoUnlocked(self, job, fields): |
|
1349 |
@staticmethod |
|
1350 |
def _GetJobInfoUnlocked(job, fields): |
|
1348 | 1351 |
"""Returns information about a job. |
1349 | 1352 |
|
1350 | 1353 |
@type job: L{_QueuedJob} |
Also available in: Unified diff