Revision 734a2a7c lib/server/masterd.py
| b/lib/server/masterd.py | ||
|---|---|---|
| 268 | 268 |
|
| 269 | 269 |
if method == luxi.REQ_SUBMIT_JOB: |
| 270 | 270 |
logging.info("Received new job")
|
| 271 |
ops = [opcodes.OpCode.LoadOpCode(state) for state in args] |
|
| 271 |
(job_def, ) = args |
|
| 272 |
ops = [opcodes.OpCode.LoadOpCode(state) for state in job_def] |
|
| 272 | 273 |
return queue.SubmitJob(ops) |
| 273 | 274 |
|
| 274 | 275 |
if method == luxi.REQ_SUBMIT_MANY_JOBS: |
| 275 | 276 |
logging.info("Received multiple jobs")
|
| 277 |
(job_defs, ) = args |
|
| 276 | 278 |
jobs = [] |
| 277 |
for ops in args:
|
|
| 279 |
for ops in job_defs:
|
|
| 278 | 280 |
jobs.append([opcodes.OpCode.LoadOpCode(state) for state in ops]) |
| 279 | 281 |
return queue.SubmitManyJobs(jobs) |
| 280 | 282 |
|
Also available in: Unified diff