From baf399fc150bc70f7128457edfab141fc3fd361f Mon Sep 17 00:00:00 2001 From: Kanwar Ujjaval Singh <4216199+kanwarujjaval@users.noreply.github.com> Date: Wed, 15 Jan 2025 19:27:32 +0530 Subject: [PATCH] progress with bookmark data --- jobServer/Job.js | 2 +- jobServer/jobRunner/impl/pulse/PulseJobExecutor.js | 5 ++++- 2 files changed, 5 insertions(+), 2 deletions(-) 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) {