From 18eb87be55002d5ca88493af39cf5c51606fa097 Mon Sep 17 00:00:00 2001
From: Dominik George <dominik.george@teckids.org>
Date: Sat, 8 Jan 2022 22:50:03 +0100
Subject: [PATCH] Only fire task if queue has tasks

---
 celery_haystack/signals.py | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/celery_haystack/signals.py b/celery_haystack/signals.py
index c6e4a0d..f37e704 100644
--- a/celery_haystack/signals.py
+++ b/celery_haystack/signals.py
@@ -29,10 +29,11 @@ class CelerySignalProcessor(RealtimeSignalProcessor):
         if settings.CELERY_HAYSTACK_COUNTDOWN:
             options['countdown'] = settings.CELERY_HAYSTACK_COUNTDOWN
 
-        task = get_update_task()
-        task.apply_async((self._queue,), {}, **options)
+        if self._queue:
+            task = get_update_task()
+            task.apply_async((self._queue,), {}, **options)
 
-        self._queue = []
+            self._queue = []
 
 
     def enqueue(self, action, instance, sender, **kwargs):
-- 
GitLab