Revision 205d71fd lib/jqueue.py
| b/lib/jqueue.py | ||
|---|---|---|
| 415 | 415 |
assert self.lock_fd, "Queue should be open" |
| 416 | 416 |
|
| 417 | 417 |
if job_id in self._memcache: |
| 418 |
logging.debug("Found job %d in memcache", job_id)
|
|
| 418 |
logging.debug("Found job %s in memcache", job_id)
|
|
| 419 | 419 |
return self._memcache[job_id] |
| 420 | 420 |
|
| 421 | 421 |
filepath = self._GetJobPath(job_id) |
| ... | ... | |
| 433 | 433 |
|
| 434 | 434 |
job = _QueuedJob.Restore(self, data) |
| 435 | 435 |
self._memcache[job_id] = job |
| 436 |
logging.debug("Added job %d to the cache", job_id)
|
|
| 436 |
logging.debug("Added job %s to the cache", job_id)
|
|
| 437 | 437 |
return job |
| 438 | 438 |
|
| 439 | 439 |
def _GetJobsUnlocked(self, job_ids): |
| ... | ... | |
| 451 | 451 |
"""Create and store on disk a new job. |
| 452 | 452 |
|
| 453 | 453 |
@type ops: list |
| 454 |
@param ops: The list of OpCodes that will becom the new job. |
|
| 454 |
@param ops: The list of OpCodes that will become the new job.
|
|
| 455 | 455 |
@type nodes: list |
| 456 | 456 |
@param nodes: The list of nodes to which the new job serial will be |
| 457 | 457 |
distributed. |
| ... | ... | |
| 466 | 466 |
# Write to disk |
| 467 | 467 |
self._UpdateJobUnlocked(job) |
| 468 | 468 |
|
| 469 |
logging.debug("Added new job %d to the cache", job_id)
|
|
| 469 |
logging.debug("Added new job %s to the cache", job_id)
|
|
| 470 | 470 |
self._memcache[job_id] = job |
| 471 | 471 |
|
| 472 | 472 |
return job |
| ... | ... | |
| 493 | 493 |
continue |
| 494 | 494 |
if job.GetStatus() not in (constants.JOB_STATUS_QUEUED, |
| 495 | 495 |
constants.JOB_STATUS_RUNNING): |
| 496 |
logging.debug("Cleaning job %d from the cache", job.id)
|
|
| 496 |
logging.debug("Cleaning job %s from the cache", job.id)
|
|
| 497 | 497 |
try: |
| 498 | 498 |
del self._memcache[job.id] |
| 499 | 499 |
except KeyError: |
Also available in: Unified diff