Revision b59252fe
| b/lib/cli.py | ||
|---|---|---|
| 1004 | 1004 |
""" |
| 1005 | 1005 |
self.queue.append((name, ops)) |
| 1006 | 1006 |
|
| 1007 |
|
|
| 1008 | 1007 |
def SubmitPending(self): |
| 1009 | 1008 |
"""Submit all pending jobs. |
| 1010 | 1009 |
|
| b/scripts/gnt-debug | ||
|---|---|---|
| 71 | 71 |
|
| 72 | 72 |
""" |
| 73 | 73 |
cl = cli.GetClient() |
| 74 |
job_data = []
|
|
| 75 |
job_ids = [] |
|
| 74 |
jex = cli.JobExecutor(cl=cl)
|
|
| 75 |
|
|
| 76 | 76 |
for fname in args: |
| 77 | 77 |
op_data = simplejson.loads(open(fname).read()) |
| 78 | 78 |
op_list = [opcodes.OpCode.LoadOpCode(val) for val in op_data] |
| 79 |
job_data.append((fname, op_list)) |
|
| 80 |
for fname, op_list in job_data: |
|
| 81 |
jid = cli.SendJob(op_list, cl=cl) |
|
| 82 |
ToStdout("File '%s', job id: %s", fname, jid)
|
|
| 83 |
job_ids.append(jid) |
|
| 84 |
for jid in job_ids: |
|
| 85 |
ToStdout("Waiting for job id %s", jid)
|
|
| 86 |
cli.PollJob(jid, cl=cl) |
|
| 79 |
jex.QueueJob("file %s" % fname, *op_list)
|
|
| 80 |
|
|
| 81 |
jex.GetResults() |
|
| 87 | 82 |
return 0 |
| 88 | 83 |
|
| 89 | 84 |
|
Also available in: Unified diff