Skip to content

Commit

Permalink
fix(worker): close lock extended timer
Browse files Browse the repository at this point in the history
  • Loading branch information
manast committed Feb 26, 2023
1 parent 4763be0 commit 7995f18
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions src/classes/worker.ts
Original file line number Diff line number Diff line change
Expand Up @@ -435,8 +435,6 @@ export class Worker<
} catch (error) {
this.running = false;
throw error;
} finally {
clearInterval(this.extendLocksTimer);
}
}

Expand Down Expand Up @@ -748,8 +746,9 @@ export class Worker<
}
return closePoolPromise;
})
.finally(() => client.disconnect())
.finally(() => clearInterval(this.extendLocksTimer))
.finally(() => clearInterval(this.stalledCheckTimer))
.finally(() => client.disconnect())
.finally(() => this.timerManager && this.timerManager.clearAllTimers())
.finally(() => this.connection.close())
.finally(() => this.emit('closed'));
Expand Down

0 comments on commit 7995f18

Please sign in to comment.