Skip to content

Commit adc351d

Browse files
committed
Fix flake8 error
1 parent bdb3252 commit adc351d

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

celery_haystack/utils.py

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,10 @@ def enqueue_task(action, instance):
3434
kwargs['queue'] = settings.CELERY_HAYSTACK_QUEUE
3535
if settings.CELERY_HAYSTACK_COUNTDOWN:
3636
kwargs['countdown'] = settings.CELERY_HAYSTACK_COUNTDOWN
37+
task = get_update_task()
3738
if hasattr(connection, 'on_commit'):
38-
connection.on_commit(lambda:get_update_task().apply_async((action, identifier), {}, **kwargs))
39+
connection.on_commit(
40+
lambda: task.apply_async((action, identifier), {}, **kwargs)
41+
)
3942
else:
40-
get_update_task().apply_async((action, identifier), {}, **kwargs)
43+
task.apply_async((action, identifier), {}, **kwargs)

0 commit comments

Comments
 (0)