Revision 346c3037 lib/jqueue.py
| b/lib/jqueue.py | ||
|---|---|---|
| 2229 | 2229 |
|
| 2230 | 2230 |
@locking.ssynchronized(_LOCK) |
| 2231 | 2231 |
@_RequireOpenQueue |
| 2232 |
def SubmitJobToDrainedQueue(self, ops): |
|
| 2233 |
"""Forcefully create and store a new job. |
|
| 2234 |
|
|
| 2235 |
Do so, even if the job queue is drained. |
|
| 2236 |
@see: L{_SubmitJobUnlocked}
|
|
| 2237 |
|
|
| 2238 |
""" |
|
| 2239 |
(job_id, ) = self._NewSerialsUnlocked(1) |
|
| 2240 |
self._EnqueueJobsUnlocked([self._SubmitJobUnlocked(job_id, ops)]) |
|
| 2241 |
return job_id |
|
| 2242 |
|
|
| 2243 |
@locking.ssynchronized(_LOCK) |
|
| 2244 |
@_RequireOpenQueue |
|
| 2232 | 2245 |
@_RequireNonDrainedQueue |
| 2233 | 2246 |
def SubmitManyJobs(self, jobs): |
| 2234 | 2247 |
"""Create and store multiple jobs. |
Also available in: Unified diff