Skip to content

Commit

Permalink
Merge pull request #18190 from mvdbeek/fix_pulsar_async_update
Browse files Browse the repository at this point in the history
[24.0] Avoid object store path lookup when constructing JobState object
  • Loading branch information
nsoranzo authored May 21, 2024
2 parents bf02164 + 44c7bb1 commit 7ba9471
Showing 1 changed file with 8 additions and 3 deletions.
11 changes: 8 additions & 3 deletions lib/galaxy/jobs/runners/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -678,14 +678,19 @@ def __init__(self, job_wrapper: "JobWrapper", job_destination: "JobDestination")
self.job_wrapper = job_wrapper
self.job_destination = job_destination
self.runner_state = None
self.exit_code_file = default_exit_code_file(job_wrapper.working_directory, job_wrapper.get_id_tag())

self.redact_email_in_job_name = True
self._exit_code_file = None
if self.job_wrapper:
self.redact_email_in_job_name = self.job_wrapper.app.config.redact_email_in_job_name

self.cleanup_file_attributes = ["job_file", "output_file", "error_file", "exit_code_file"]

@property
def exit_code_file(self) -> str:
return self._exit_code_file or default_exit_code_file(
self.job_wrapper.working_directory, self.job_wrapper.get_id_tag()
)

def set_defaults(self, files_dir):
if self.job_wrapper is not None:
id_tag = self.job_wrapper.get_id_tag()
Expand Down Expand Up @@ -753,7 +758,7 @@ def __init__(
self.output_file = output_file
self.error_file = error_file
if exit_code_file:
self.exit_code_file = exit_code_file
self._exit_code_file = exit_code_file
self.job_name = job_name

self.set_defaults(files_dir)
Expand Down

0 comments on commit 7ba9471

Please sign in to comment.