diff --git a/celery_haystack/signals.py b/celery_haystack/signals.py
index c6e4a0d752ed9ffa90680efd6a06740c78b548df..f37e7048c523d8e52017ec4b4a06ed0d2215e63d 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):