Revision 69b03fd7 lib/jqueue.py
| b/lib/jqueue.py | ||
|---|---|---|
| 919 | 919 |
else: |
| 920 | 920 |
return None |
| 921 | 921 |
|
| 922 |
def _GetJobIDsUnlocked(self, archived=False):
|
|
| 922 |
def _GetJobIDsUnlocked(self): |
|
| 923 | 923 |
"""Return all known job IDs. |
| 924 | 924 |
|
| 925 |
If the parameter archived is True, archived jobs IDs will be |
|
| 926 |
included. Currently this argument is unused. |
|
| 927 |
|
|
| 928 | 925 |
The method only looks at disk because it's a requirement that all |
| 929 | 926 |
jobs are present on disk (so in the _memcache we don't have any |
| 930 | 927 |
extra IDs). |
| ... | ... | |
| 933 | 930 |
@return: the list of job IDs |
| 934 | 931 |
|
| 935 | 932 |
""" |
| 936 |
# pylint: disable-msg=W0613 |
|
| 937 | 933 |
jlist = [self._ExtractJobID(name) for name in self._ListJobFiles()] |
| 938 | 934 |
jlist = utils.NiceSort(jlist) |
| 939 | 935 |
return jlist |
| ... | ... | |
| 1319 | 1315 |
archived_count = 0 |
| 1320 | 1316 |
last_touched = 0 |
| 1321 | 1317 |
|
| 1322 |
all_job_ids = self._GetJobIDsUnlocked(archived=False)
|
|
| 1318 |
all_job_ids = self._GetJobIDsUnlocked() |
|
| 1323 | 1319 |
pending = [] |
| 1324 | 1320 |
for idx, job_id in enumerate(all_job_ids): |
| 1325 | 1321 |
last_touched = idx + 1 |
Also available in: Unified diff