diff --git a/jobServer/Job.js b/jobServer/Job.js index 6652d954c38..3119717731b 100644 --- a/jobServer/Job.js +++ b/jobServer/Job.js @@ -268,7 +268,7 @@ class Job { // Touch to prevent lock expiration if (this.#touchMethod) { - await this.#touchMethod(); + await this.#touchMethod(progress); } this.logger?.d(`Progress reported for job "${this.jobName}":`, progressData); diff --git a/jobServer/jobRunner/impl/pulse/PulseJobExecutor.js b/jobServer/jobRunner/impl/pulse/PulseJobExecutor.js index 1016800817e..f0d5940e6bf 100644 --- a/jobServer/jobRunner/impl/pulse/PulseJobExecutor.js +++ b/jobServer/jobRunner/impl/pulse/PulseJobExecutor.js @@ -151,7 +151,10 @@ class PulseJobExecutor extends IJobExecutor { */ async #updateJobProgress(job, progressData) { try { - job.data = progressData; + job.attrs.data = { + ...job.attrs.data, + progressData + }; await job.save(); } catch (error) {