Revision f87b405e lib/jqueue.py
| b/lib/jqueue.py | ||
|---|---|---|
| 941 | 941 |
""" |
| 942 | 942 |
if self._IsQueueMarkedDrain(): |
| 943 | 943 |
raise errors.JobQueueDrainError() |
| 944 |
|
|
| 945 |
# Check job queue size |
|
| 946 |
size = len(self._ListJobFiles()) |
|
| 947 |
if size >= constants.JOB_QUEUE_SIZE_SOFT_LIMIT: |
|
| 948 |
# TODO: Autoarchive jobs. Make sure it's not done on every job |
|
| 949 |
# submission, though. |
|
| 950 |
#size = ... |
|
| 951 |
pass |
|
| 952 |
|
|
| 953 |
if size >= constants.JOB_QUEUE_SIZE_HARD_LIMIT: |
|
| 954 |
raise errors.JobQueueFull() |
|
| 955 |
|
|
| 944 | 956 |
# Get job identifier |
| 945 | 957 |
job_id = self._NewSerialUnlocked() |
| 946 | 958 |
job = _QueuedJob(self, job_id, ops) |
Also available in: Unified diff