Revision 21cc1fbd
| b/lib/jqueue.py | ||
|---|---|---|
| 264 | 264 |
self.context = context |
| 265 | 265 |
|
| 266 | 266 |
|
| 267 |
class JobStorage(object): |
|
| 267 |
class DiskJobStorage(object):
|
|
| 268 | 268 |
_RE_JOB_FILE = re.compile(r"^job-(%s)$" % constants.JOB_ID_TEMPLATE) |
| 269 | 269 |
|
| 270 | 270 |
def __init__(self): |
| ... | ... | |
| 513 | 513 |
""" |
| 514 | 514 |
def __init__(self, context): |
| 515 | 515 |
self._lock = threading.Lock() |
| 516 |
self._jobs = JobStorage() |
|
| 516 |
self._jobs = DiskJobStorage()
|
|
| 517 | 517 |
self._wpool = _JobQueueWorkerPool(context) |
| 518 | 518 |
|
| 519 | 519 |
for job in self._jobs.GetJobs(None): |
Also available in: Unified diff