Revision 2cb687ad
| b/lib/cli.py | ||
|---|---|---|
| 380 | 380 |
# TODO: Fix feedback_fn situation. |
| 381 | 381 |
cl = luxi.Client() |
| 382 | 382 |
job = opcodes.Job(op_list=[op]) |
| 383 |
jid = SubmitJob(job) |
|
| 383 |
jid = SubmitJob(job, cl)
|
|
| 384 | 384 |
|
| 385 | 385 |
query = {
|
| 386 | 386 |
"object": "jobs", |
| ... | ... | |
| 389 | 389 |
} |
| 390 | 390 |
|
| 391 | 391 |
while True: |
| 392 |
jdata = SubmitQuery(query) |
|
| 392 |
jdata = SubmitQuery(query, cl)
|
|
| 393 | 393 |
if not jdata: |
| 394 | 394 |
# job not found, go away! |
| 395 | 395 |
raise errors.JobLost("Job with id %s lost" % jid)
|
| ... | ... | |
| 400 | 400 |
time.sleep(1) |
| 401 | 401 |
|
| 402 | 402 |
query["fields"].extend(["op_list", "op_status", "op_result"]) |
| 403 |
jdata = SubmitQuery(query) |
|
| 403 |
jdata = SubmitQuery(query, cl)
|
|
| 404 | 404 |
if not jdata: |
| 405 | 405 |
raise errors.JobLost("Job with id %s lost" % jid)
|
| 406 | 406 |
status, op_list, op_status, op_result = jdata[0] |
Also available in: Unified diff