Skip to content

Commit

Permalink
Put cached jobs back into queue on handler restart
Browse files Browse the repository at this point in the history
and don't recover job wrapper, which will fail since we don't actually
create a job working directory for cached jobs.
  • Loading branch information
mvdbeek committed Oct 16, 2024
1 parent fa575f8 commit af5bee1
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions lib/galaxy/jobs/handler.py
Original file line number Diff line number Diff line change
Expand Up @@ -309,6 +309,8 @@ def _check_job_at_startup(self, job):
self.job_wrapper(job).fail(
"This tool was disabled before the job completed. Please contact your Galaxy administrator."
)
elif job.copied_from_job_id:
self.queue.put((job.id, job.tool_id))
elif job.job_runner_name is not None and job.job_runner_external_id is None:
# This could happen during certain revisions of Galaxy where a runner URL was persisted before the job was dispatched to a runner.
log.debug(f"({job.id}) Job runner assigned but no external ID recorded, adding to the job handler queue")
Expand Down

0 comments on commit af5bee1

Please sign in to comment.