From 24bdefb1db41f7763928403763eccf82309aacf7 Mon Sep 17 00:00:00 2001
From: Dominik George <dominik.george@teckids.org>
Date: Sat, 8 Jan 2022 22:46:45 +0100
Subject: [PATCH] Clear queue when task was fired
---
celery_haystack/signals.py | 2 ++
1 file changed, 2 insertions(+)
diff --git a/celery_haystack/signals.py b/celery_haystack/signals.py
index 1c7974f..c6e4a0d 100644
--- a/celery_haystack/signals.py
+++ b/celery_haystack/signals.py
@@ -32,6 +32,8 @@ class CelerySignalProcessor(RealtimeSignalProcessor):
task = get_update_task()
task.apply_async((self._queue,), {}, **options)
+ self._queue = []
+
def enqueue(self, action, instance, sender, **kwargs):
"""
--
GitLab