diff --git a/celery_haystack/signals.py b/celery_haystack/signals.py index 79fa813da0db088a9f929d5d585f00260b1de3b9..5fc20b0fe8d3410f74f6921ec0775163b4b65566 100644 --- a/celery_haystack/signals.py +++ b/celery_haystack/signals.py @@ -4,7 +4,7 @@ from haystack.signals import BaseSignalProcessor from haystack.exceptions import NotHandled from haystack.utils import get_identifier -from .utils import enqueue_tasks +from .utils import enqueue_task from .indexes import CelerySearchIndex @@ -20,7 +20,7 @@ class CelerySignalProcessor(BaseSignalProcessor): signals.post_save.disconnect(self.enqueue_save) signals.post_delete.disconnect(self.enqueue_delete) - enqueue_tasks(self._queue) + enqueue_task(self._queue) def enqueue_save(self, sender, instance, **kwargs): return self.enqueue('update', instance, sender, **kwargs) diff --git a/celery_haystack/utils.py b/celery_haystack/utils.py index 7b6af695fca946c77e8f98addaedf2221cd4065d..24528d1545a1114592fbd6359150373aab276806 100644 --- a/celery_haystack/utils.py +++ b/celery_haystack/utils.py @@ -24,7 +24,7 @@ def get_update_task(task_path=None): return task -def enqueue_tasks(queue, **kwargs): +def enqueue_task(queue, **kwargs): """ Common utility for enqueing a task for the given action and model instance.