@auvipy this change broke quite a few tests within thetest_task_retries test class 😠 started to track down the issue(s) but ran out of time. Will continue to work through the failures but wanted to get the PR opened so you could get 👀 on it

it seems you didn't pick all the needed parts here. you can check the old pr

Hi! Any updates here? I can't test the retry logic without this change. Thank you!

Hi! Any updates here? I can't test the retry logic without this change. Thank you!

Unfortunately, I haven't put any more time into this. I appreciate and welcome any support on this PR!

I tried changing it to this w/o success. My tasks do get called multiple times in my tests, that part is fixed, but the return value isn't getting through. Not sure what I'm missing:

        ret = Retry(exc=exc, when=eta or countdown, is_eager=is_eager, sig=S)        if is_eager:            # if task was executed eagerly using apply(),            # then the retry must also be executed eagerly in apply method            retry_ret = S.apply().get()            if throw:                raise ret            return retry_ret

Tried with justS.apply() andreturn ret vsreturn retry_ret with no success. Sorry, I'm just not familiar with what is supposed to happen here, but I thought I'd poke around to see if I could get it work.