Revision b7cb9024 lib/jqueue.py
| 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