diff --git a/celery_haystack/conf.py b/celery_haystack/conf.py index 26f278ae90c199415c685157c78703f10eb138fd..c88c488aad96f389c08fb7b664e2a6ed6180620e 100644 --- a/celery_haystack/conf.py +++ b/celery_haystack/conf.py @@ -20,6 +20,8 @@ class CeleryHaystack(AppConf): QUEUE = None #: Whether the task should be handled transaction safe TRANSACTION_SAFE = True + #: Whether the task results should be ignored + IGNORE_RESULT = False #: The batch size used by the CeleryHaystackUpdateIndex task COMMAND_BATCH_SIZE = None diff --git a/celery_haystack/tasks.py b/celery_haystack/tasks.py index d8acedd3fa94619c617fbc623b600816d8e00c35..e2a1ce0d6ece4e5480517482b1b90d9643edfb32 100644 --- a/celery_haystack/tasks.py +++ b/celery_haystack/tasks.py @@ -17,6 +17,8 @@ class CeleryHaystackSignalHandler(Task): using = settings.CELERY_HAYSTACK_DEFAULT_ALIAS max_retries = settings.CELERY_HAYSTACK_MAX_RETRIES default_retry_delay = settings.CELERY_HAYSTACK_RETRY_DELAY + ignore_result = settings.CELERY_HAYSTACK_IGNORE_RESULT + store_errors_even_if_ignored = True def split_identifier(self, identifier, **kwargs): """