Revision 4c848b18 lib/jqueue.py
| b/lib/jqueue.py | ||
|---|---|---|
| 362 | 362 |
|
| 363 | 363 |
return str(job_id) |
| 364 | 364 |
|
| 365 |
def _NewSerialUnlocked(self, nodes):
|
|
| 365 |
def _NewSerialUnlocked(self): |
|
| 366 | 366 |
"""Generates a new job identifier. |
| 367 | 367 |
|
| 368 | 368 |
Job identifiers are unique during the lifetime of a cluster. |
| ... | ... | |
| 448 | 448 |
|
| 449 | 449 |
@utils.LockedMethod |
| 450 | 450 |
@_RequireOpenQueue |
| 451 |
def SubmitJob(self, ops, nodes):
|
|
| 451 |
def SubmitJob(self, ops): |
|
| 452 | 452 |
"""Create and store a new job. |
| 453 | 453 |
|
| 454 | 454 |
This enters the job into our job queue and also puts it on the new |
| ... | ... | |
| 456 | 456 |
|
| 457 | 457 |
@type ops: list |
| 458 | 458 |
@param ops: The list of OpCodes that will become the new job. |
| 459 |
@type nodes: list |
|
| 460 |
@param nodes: The list of nodes to which the new job serial will be |
|
| 461 |
distributed. |
|
| 462 | 459 |
|
| 463 | 460 |
""" |
| 464 | 461 |
# Get job identifier |
| 465 |
job_id = self._NewSerialUnlocked(nodes)
|
|
| 462 |
job_id = self._NewSerialUnlocked() |
|
| 466 | 463 |
job = _QueuedJob(self, job_id, ops) |
| 467 | 464 |
|
| 468 | 465 |
# Write to disk |
Also available in: Unified diff