Unverified Commit 3c798e7b authored by mvdbeek's avatar mvdbeek
Browse files

Skip limit check for tasks 

I assume these are limited on the job level ...
parent e84e7156

lib/galaxy/jobs/__init__.py

+3 −1
Original line number Diff line number Diff line
@@ -1727,7 +1727,9 @@ class MinimalJobWrapper(HasResourceParameters): 
    def enqueue(self):

        job = self.get_job()

        # Change to queued state before handing to worker thread so the runner won't pick it up again

        if not self.queue_with_limit(job, self.job_destination):

        if self.is_task:

            self.change_state(model.Job.states.QUEUED, flush=False, job=job)

        elif not self.queue_with_limit(job, self.job_destination):

            return False

        # Set object store after job destination so can leverage parameters...

        self._set_object_store_ids(job)