Remove a job from queue if it hasn't been executed yet.
(job_id)
| 145 | |
| 146 | |
| 147 | def dequeue_job(job_id): |
| 148 | """Remove a job from queue if it hasn't been executed yet.""" |
| 149 | |
| 150 | for queue in queues.values(): |
| 151 | if job_id in queue.jobs: |
| 152 | queue.remove(job_id) |
| 153 | |
| 154 | |
| 155 | def compute_queue_load_factor(): |