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