|
@@ -562,9 +562,11 @@ class BaseTask(object):
|
|
|
"eta": eta})
|
|
|
|
|
|
if max_retries is not None and options["retries"] > max_retries:
|
|
|
- raise exc or self.MaxRetriesExceededError(
|
|
|
- "Can't retry %s[%s] args:%s kwargs:%s" % (
|
|
|
- self.name, options["task_id"], args, kwargs))
|
|
|
+ if exc:
|
|
|
+ raise
|
|
|
+ raise self.MaxRetriesExceededError(
|
|
|
+ "Can't retry %s[%s] args:%s kwargs:%s" % (
|
|
|
+ self.name, options["task_id"], args, kwargs))
|
|
|
|
|
|
# If task was executed eagerly using apply(),
|
|
|
# then the retry must also be executed eagerly.
|