Revision b7cb9024
b/lib/jqueue.py | ||
---|---|---|
542 | 542 |
logging.info("Inspecting job queue") |
543 | 543 |
|
544 | 544 |
all_job_ids = self._GetJobIDsUnlocked() |
545 |
jobs_count = len(all_job_ids) |
|
545 | 546 |
lastinfo = time.time() |
546 | 547 |
for idx, job_id in enumerate(all_job_ids): |
547 | 548 |
# Give an update every 1000 jobs or 10 seconds |
548 |
if idx % 1000 == 0 or time.time() >= (lastinfo + 10.0):
|
|
549 |
jobs_count = len(all_job_ids)
|
|
549 |
if (idx % 1000 == 0 or time.time() >= (lastinfo + 10.0) or
|
|
550 |
idx == (jobs_count - 1)):
|
|
550 | 551 |
logging.info("Job queue inspection: %d/%d (%0.1f %%)", |
551 |
idx, jobs_count, 100.0 * (idx + 1) / jobs_count) |
|
552 |
idx, jobs_count - 1, 100.0 * (idx + 1) / jobs_count)
|
|
552 | 553 |
lastinfo = time.time() |
553 | 554 |
|
554 | 555 |
job = self._LoadJobUnlocked(job_id) |
Also available in: Unified diff