Skip to content

Commit

Permalink
progress with bookmark data
Browse files Browse the repository at this point in the history
  • Loading branch information
kanwarujjaval committed Jan 15, 2025
1 parent 5acfa2f commit baf399f
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 2 deletions.
2 changes: 1 addition & 1 deletion jobServer/Job.js
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand Down
5 changes: 4 additions & 1 deletion jobServer/jobRunner/impl/pulse/PulseJobExecutor.js
Original file line number Diff line number Diff line change
Expand Up @@ -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) {
Expand Down

0 comments on commit baf399f

Please sign in to comment.