From 0f81e3d452b3371dedcab0bdeb04b2c7e92cb382 Mon Sep 17 00:00:00 2001
From: Dominik George <dominik.george@teckids.org>
Date: Sat, 8 Jan 2022 20:51:01 +0100
Subject: [PATCH] Rename enqueue_tasks to enqueue_task again
---
celery_haystack/signals.py | 4 ++--
celery_haystack/utils.py | 2 +-
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/celery_haystack/signals.py b/celery_haystack/signals.py
index 79fa813..5fc20b0 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 7b6af69..24528d1 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.
--
GitLab