diff --git a/celery_haystack/signals.py b/celery_haystack/signals.py index f952f99..059d2e8 100644 --- a/celery_haystack/signals.py +++ b/celery_haystack/signals.py @@ -39,6 +39,6 @@ def enqueue(self, action, instance, sender, **kwargs): continue # Check next backend if isinstance(index, CelerySearchIndex): - if action == 'update' and not index.should_update(instance): + if action == 'update' and not index.should_update(instance, **kwargs): continue enqueue_task(action, instance)