Unverified Commit 0b302d27 authored by mvdbeek's avatar mvdbeek
Browse files

Drop redundant queued state in pulsar

parent 3e767c94

lib/galaxy/jobs/runners/pulsar.py

+1 −3
Original line number Diff line number Diff line
@@ -451,9 +451,7 @@ class PulsarJobRunner(AsynchronousJobRunner): 
            job = job_wrapper.get_job()

            # Set the job destination here (unlike other runners) because there are likely additional job destination

            # params from the Pulsar client.

            # Flush with change_state.

            job_wrapper.set_job_destination(job_destination, external_id=external_job_id, flush=False, job=job)

            job_wrapper.change_state(model.Job.states.QUEUED, job=job)

            job_wrapper.set_job_destination(job_destination, external_id=external_job_id, flush=True, job=job)

        except Exception:

            job_wrapper.fail("failure running job", exception=True)

            log.exception("failure running job %d", job_wrapper.job_id)