add the retry counter to the retryTaskIn() function so it actually us…

…es the retry counter specified.
klippa-app · Sep 28, 2021 · f0a0997 · f0a0997
1 parent 53e2e28
commit f0a0997
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/v1/worker.go b/v1/worker.go
@@ -231,6 +231,9 @@ func (worker *Worker) retryTaskIn(signature *tasks.Signature, retryIn time.Durat
 		return fmt.Errorf("Set state to 'retry' for task %s returned error: %s", signature.UUID, err)
 	}
 
+	// Decrement the retry counter, when it reaches 0, we won't retry again
+	signature.RetryCount--
+
 	// Delay task by retryIn duration
 	eta := time.Now().UTC().Add(retryIn)
 	signature.ETA = &eta