X-Git-Url: https://git.mdrn.pl/redakcja.git/blobdiff_plain/4395564bb09e6b7d74cae3421f6342dd546b5619..818b7ba3c373f6a10c70224d8650cdcbbd3bcd75:/apps/catalogue/tasks.py diff --git a/apps/catalogue/tasks.py b/apps/catalogue/tasks.py index 53b867b4..c84a2912 100644 --- a/apps/catalogue/tasks.py +++ b/apps/catalogue/tasks.py @@ -3,7 +3,7 @@ from django.utils import translation from django.conf import settings -@task +@task(ignore_result=True) def _refresh_by_pk(cls, pk, language=None): prev_language = translation.get_language() language and translation.activate(language) @@ -12,12 +12,8 @@ def _refresh_by_pk(cls, pk, language=None): finally: translation.activate(prev_language) -if settings.USE_CELERY: - def refresh_instance(instance): - _refresh_by_pk.delay(type(instance), instance.pk, translation.get_language()) -else: - def refresh_instance(instance): - instance.refresh() +def refresh_instance(instance): + _refresh_by_pk.delay(type(instance), instance.pk, translation.get_language()) @task @@ -33,10 +29,11 @@ def _publishable_error(book, language=None): finally: translation.activate(prev_language) -if settings.USE_CELERY: - def publishable_error(book): - task = _publishable_error.delay(book, translation.get_language()) - return task.wait() -else: - def publishable_error(book): - return _publishable_error(book) +def publishable_error(book): + return _publishable_error.delay(book, + translation.get_language()).wait() + + +@task(ignore_result=True) +def book_content_updated(book): + book.refresh_dc_cache()