Revision 02fc74da lib/jqueue.py
| b/lib/jqueue.py | ||
|---|---|---|
| 430 | 430 |
@param job: the job to be processed |
| 431 | 431 |
|
| 432 | 432 |
""" |
| 433 |
logging.info("Worker %s processing job %s",
|
|
| 434 |
self.worker_id, job.id) |
|
| 433 |
logging.info("Processing job %s", job.id)
|
|
| 435 | 434 |
proc = mcpu.Processor(self.pool.queue.context, job.id) |
| 436 | 435 |
queue = job.queue |
| 437 | 436 |
try: |
| ... | ... | |
| 527 | 526 |
finally: |
| 528 | 527 |
queue.release() |
| 529 | 528 |
|
| 530 |
logging.info("Worker %s finished job %s, status = %s",
|
|
| 531 |
self.worker_id, job_id, status) |
|
| 529 |
logging.info("Finished job %s, status = %s", job_id, status)
|
|
| 532 | 530 |
|
| 533 | 531 |
|
| 534 | 532 |
class _JobQueueWorkerPool(workerpool.WorkerPool): |
Also available in: Unified diff