Revision 56d8ff91 daemons/ganeti-masterd
b/daemons/ganeti-masterd | ||
---|---|---|
214 | 214 |
ops = [opcodes.OpCode.LoadOpCode(state) for state in args] |
215 | 215 |
return queue.SubmitJob(ops) |
216 | 216 |
|
217 |
if method == luxi.REQ_SUBMIT_MANY_JOBS: |
|
218 |
logging.info("Received multiple jobs") |
|
219 |
jobs = [] |
|
220 |
for ops in args: |
|
221 |
jobs.append([opcodes.OpCode.LoadOpCode(state) for state in ops]) |
|
222 |
return queue.SubmitManyJobs(jobs) |
|
223 |
|
|
217 | 224 |
elif method == luxi.REQ_CANCEL_JOB: |
218 | 225 |
job_id = args |
219 | 226 |
logging.info("Received job cancel request for %s", job_id) |
Also available in: Unified diff