X-Git-Url: https://git.mdrn.pl/redakcja.git/blobdiff_plain/4395564bb09e6b7d74cae3421f6342dd546b5619..d9bec7e66b9e33e3aca3cca1abd78e9151b5d03a:/apps/catalogue/tasks.py?ds=inline diff --git a/apps/catalogue/tasks.py b/apps/catalogue/tasks.py index 53b867b4..c386c22b 100644 --- a/apps/catalogue/tasks.py +++ b/apps/catalogue/tasks.py @@ -1,9 +1,8 @@ from celery.task import task 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,31 +11,10 @@ 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 -def _publishable_error(book, language=None): - prev_language = translation.get_language() - language and translation.activate(language) - try: - return book.assert_publishable() - except AssertionError, e: - return e - else: - return 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) +@task(ignore_result=True) +def book_content_updated(book): + book.refresh_dc_cache()