@mchataigner Can you help on that for tests?

@Ixiodor do you have a code sample so that I may understand better the issue here?

@mchataigner
Use somenthing like that:

import random

@app.task(name="TestTask", bind=True, autoretry_for=(Exception,),
                  max_retries=10)
def foo(self):
    number = random.randint(0, 1)
    if number % 2 == 0: # I wanna retry in that case
        print(str(number) + " : going to retry")
        self.retry(exc=Exception('Trying again...'))
    else: # I wanna fail elsewhere
        print(str(number) + " : going to fail")
        self.retry(exc=Exception('You failed'), max_retries=0) # That one should tell to stop retries

foo.si().delay()

This example will run always 11 times. No matter which route.
I wanna retry in some cases but i wanna fail in other cases, i wanna fail forcing no more retries. Retry is an Exception, so it get caught by autoretry_for=(Exception,), Retry will check for max_retries and max_retries is 0, so it should stop retry and launch the exc exception, but exc exception will be caught again by autoretry_for=(Exception,) and in this case you can't override max_retries, so the decorator(or default) max_retries will apply, making max_retries override in self.retry useless. This patch set a new max_retries for task and it's wrong with the starting idea, we have to find a way to set max_retries on exc launched by self.retry with same values overrided with self.retry or make exc escape from autoretry_for.

I found a trick:

    else: # I wanna fail elsewhere
        print(str(number) + " : going to fail")
        self.retry(exc=Retry('You failed'), max_retries=0)

That works cause Retry is protected from autoretry_for. Should we create another protected Exception? (Something like BypassException) That incapsulate the real Exception and on except will raise the one inside BypassExpcetion container.

Made a PR that seems better than this.
#6436