X-Git-Url: https://git.mdrn.pl/redakcja.git/blobdiff_plain/1019e504d3ffa1edc034428d5e3b5cbf7bd2fc4f..8690530da093fc9875def2ed479497211c215e5e:/apps/catalogue/tasks.py?ds=sidebyside diff --git a/apps/catalogue/tasks.py b/apps/catalogue/tasks.py index ca696256..9507c412 100644 --- a/apps/catalogue/tasks.py +++ b/apps/catalogue/tasks.py @@ -1,3 +1,4 @@ +# -*- coding: utf-8 -*- from celery.task import task from django.utils import translation @@ -5,34 +6,20 @@ from django.utils import translation @task(ignore_result=True) def _refresh_by_pk(cls, pk, language=None): prev_language = translation.get_language() - language and translation.activate(language) + if language: + translation.activate(language) try: cls._default_manager.get(pk=pk).refresh() + except cls.DoesNotExist: + pass finally: translation.activate(prev_language) + 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) - -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()