-
Notifications
You must be signed in to change notification settings - Fork 390
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
perf(retry): delete props in retryJob lua script #1016
Conversation
@@ -20,6 +21,7 @@ if (rcall("EXISTS", KEYS[1]) == 1) then | |||
local jobId = ARGV[1] | |||
if (rcall("ZREM", KEYS[3], jobId) == 1) then | |||
rcall(ARGV[2], KEYS[4], jobId) | |||
rcall("HDEL", KEYS[1], "finishedOn", "processedOn", ARGV[3]) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
probably we should set attempstMade as 0 too, what do you think @manast ?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Not sure, why would we like to reset the number of attempts here?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
if the job failed after the last attempt, if we retry the job, it would keep the last maximum attempt number
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
as we are not going to reset the attempstMade, this pr should be ready
src/classes/job.ts
Outdated
@@ -844,23 +844,16 @@ export class Job< | |||
/** | |||
* Attempts to retry the job. Only a job that has failed can be retried. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Since we can actually retry completed jobs, this comment is incorrect right now.
🎉 This PR is included in version 1.67.1 🎉 The release is available on: Your semantic-release bot 📦🚀 |
No description provided.