瀏覽代碼

Error mails should not be sent when the task is retried, so don't return exception in execute()

Ask Solem 15 年之前
父節點
當前提交
4ac76987c3
共有 1 個文件被更改,包括 2 次插入1 次删除
  1. 2 1
      celery/execute.py

+ 2 - 1
celery/execute.py

@@ -262,7 +262,8 @@ class ExecuteWrapper(object):
         except (SystemExit, KeyboardInterrupt):
         except (SystemExit, KeyboardInterrupt):
             raise
             raise
         except RetryTaskError, exc:
         except RetryTaskError, exc:
-            retval = self.handle_retry(exc, sys.exc_info())
+            self.handle_retry(exc, sys.exc_info())
+            retval = None
         except Exception, exc:
         except Exception, exc:
             retval = self.handle_failure(exc, sys.exc_info())
             retval = self.handle_failure(exc, sys.exc_info())
         else:
         else: