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