diff --git a/celery_haystack/utils.py b/celery_haystack/utils.py index 24528d1545a1114592fbd6359150373aab276806..b016e6cc62be1ef1af5436cb19ab1bb3db45fc87 100644 --- a/celery_haystack/utils.py +++ b/celery_haystack/utils.py @@ -36,7 +36,7 @@ def enqueue_task(queue, **kwargs): options['countdown'] = settings.CELERY_HAYSTACK_COUNTDOWN task = get_update_task() - task_func = lambda: task.apply_async(queue, kwargs, **options) + task_func = lambda: task.apply_async((queue,), kwargs, **options) if hasattr(transaction, 'on_commit'): # Django 1.9 on_commit hook