Skip to content
Snippets Groups Projects
Verified Commit 0f81e3d4 authored by Nik | Klampfradler's avatar Nik | Klampfradler
Browse files

Rename enqueue_tasks to enqueue_task again

parent 7f7cf9ce
No related branches found
Tags 1.0.3
No related merge requests found
...@@ -4,7 +4,7 @@ from haystack.signals import BaseSignalProcessor ...@@ -4,7 +4,7 @@ from haystack.signals import BaseSignalProcessor
from haystack.exceptions import NotHandled from haystack.exceptions import NotHandled
from haystack.utils import get_identifier from haystack.utils import get_identifier
from .utils import enqueue_tasks from .utils import enqueue_task
from .indexes import CelerySearchIndex from .indexes import CelerySearchIndex
...@@ -20,7 +20,7 @@ class CelerySignalProcessor(BaseSignalProcessor): ...@@ -20,7 +20,7 @@ class CelerySignalProcessor(BaseSignalProcessor):
signals.post_save.disconnect(self.enqueue_save) signals.post_save.disconnect(self.enqueue_save)
signals.post_delete.disconnect(self.enqueue_delete) signals.post_delete.disconnect(self.enqueue_delete)
enqueue_tasks(self._queue) enqueue_task(self._queue)
def enqueue_save(self, sender, instance, **kwargs): def enqueue_save(self, sender, instance, **kwargs):
return self.enqueue('update', instance, sender, **kwargs) return self.enqueue('update', instance, sender, **kwargs)
......
...@@ -24,7 +24,7 @@ def get_update_task(task_path=None): ...@@ -24,7 +24,7 @@ def get_update_task(task_path=None):
return task return task
def enqueue_tasks(queue, **kwargs): def enqueue_task(queue, **kwargs):
""" """
Common utility for enqueing a task for the given action and Common utility for enqueing a task for the given action and
model instance. model instance.
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment