Revision af30b2fd lib/jqueue.py
| b/lib/jqueue.py | ||
|---|---|---|
| 47 | 47 |
self._lock = threading.Lock() |
| 48 | 48 |
|
| 49 | 49 |
@utils.LockedMethod |
| 50 |
def GetInput(self): |
|
| 51 |
"""Returns the original opcode. |
|
| 52 |
|
|
| 53 |
""" |
|
| 54 |
return self.input |
|
| 55 |
|
|
| 56 |
@utils.LockedMethod |
|
| 50 | 57 |
def SetStatus(self, status, result): |
| 51 | 58 |
"""Update the opcode status and result. |
| 52 | 59 |
|
| ... | ... | |
| 228 | 235 |
row.append(job.id) |
| 229 | 236 |
elif fname == "status": |
| 230 | 237 |
row.append(job.GetStatus()) |
| 231 |
elif fname == "result": |
|
| 232 |
# TODO |
|
| 238 |
elif fname == "ops": |
|
| 239 |
row.append([op.GetInput().__getstate__() for op in job._ops]) |
|
| 240 |
elif fname == "opresult": |
|
| 233 | 241 |
row.append([op.GetResult() for op in job._ops]) |
| 242 |
elif fname == "opstatus": |
|
| 243 |
row.append([op.GetStatus() for op in job._ops]) |
|
| 234 | 244 |
else: |
| 235 | 245 |
raise errors.OpExecError("Invalid job query field '%s'" % fname)
|
| 236 | 246 |
return row |
Also available in: Unified diff