Revision 346c3037 lib/server/masterd.py
b/lib/server/masterd.py | ||
---|---|---|
295 | 295 |
_LogNewJob(True, job_id, ops) |
296 | 296 |
return job_id |
297 | 297 |
|
298 |
elif method == luxi.REQ_SUBMIT_JOB_TO_DRAINED_QUEUE: |
|
299 |
logging.info("Forcefully receiving new job") |
|
300 |
(job_def, ) = args |
|
301 |
ops = [opcodes.OpCode.LoadOpCode(state) for state in job_def] |
|
302 |
job_id = queue.SubmitJobToDrainedQueue(ops) |
|
303 |
_LogNewJob(True, job_id, ops) |
|
304 |
return job_id |
|
305 |
|
|
298 | 306 |
elif method == luxi.REQ_SUBMIT_MANY_JOBS: |
299 | 307 |
logging.info("Receiving multiple jobs") |
300 | 308 |
(job_defs, ) = args |
Also available in: Unified diff