don't remove from the queue even if it's running.

May want to reinstitute this in the future.
learningequality · May 23, 2017 · 23ba84d · 23ba84d
1 parent 01d0640
commit 23ba84d
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/src/barbequeue/storage/backends/inmem.py b/src/barbequeue/storage/backends/inmem.py
@@ -86,9 +86,6 @@ def mark_job_as_running(self, job_id):
         job = self._get_job_nocopy(job_id)
         job.state = Job.State.RUNNING
 
-        # Remove job from queue
-        self.queue.remove(job_id)
-
     def complete_job(self, job_id):
         job = self._get_job_nocopy(job_id)