Revision 42d49574
b/lib/jqueue.py | ||
---|---|---|
2056 | 2056 |
|
2057 | 2057 |
job = _QueuedJob(self, job_id, ops, True) |
2058 | 2058 |
|
2059 |
# Check priority |
|
2060 | 2059 |
for idx, op in enumerate(job.ops): |
2060 |
# Check priority |
|
2061 | 2061 |
if op.priority not in constants.OP_PRIO_SUBMIT_VALID: |
2062 | 2062 |
allowed = utils.CommaJoin(constants.OP_PRIO_SUBMIT_VALID) |
2063 | 2063 |
raise errors.GenericError("Opcode %s has invalid priority %s, allowed" |
2064 | 2064 |
" are %s" % (idx, op.priority, allowed)) |
2065 | 2065 |
|
2066 |
# Check job dependencies |
|
2066 | 2067 |
dependencies = getattr(op.input, opcodes.DEPEND_ATTR, None) |
2067 | 2068 |
if not opcodes.TNoRelativeJobDependencies(dependencies): |
2068 | 2069 |
raise errors.GenericError("Opcode %s has invalid dependencies, must" |
Also available in: Unified diff