X-Git-Url: https://git.mdrn.pl/wolnelektury.git/blobdiff_plain/29a13b9e77d5a7ac5d26c95488028f88e6b57c2f..6dd3e47a80aeb8d0208bcbfdaaa6275d0cceae3d:/apps/catalogue/tasks.py?ds=sidebyside diff --git a/apps/catalogue/tasks.py b/apps/catalogue/tasks.py index 663a5bce4..e392ae2da 100644 --- a/apps/catalogue/tasks.py +++ b/apps/catalogue/tasks.py @@ -7,24 +7,18 @@ from traceback import print_exc from celery.task import task from django.conf import settings from wolnelektury.utils import localtime_to_utc +from waiter.models import WaitedFile # TODO: move to model? def touch_tag(tag): update_dict = { - 'book_count': tag.get_count(), - 'picture_count': tag.get_picture_count(), 'changed_at': localtime_to_utc(datetime.now()), } type(tag).objects.filter(pk=tag.pk).update(**update_dict) -@task(ignore_result=True) -def fix_tree_tags(book): - book.fix_tree_tags() - - @task def index_book(book_id, book_info=None, **kwargs): from catalogue.models import Book @@ -37,22 +31,26 @@ def index_book(book_id, book_info=None, **kwargs): @task(ignore_result=True, rate_limit=settings.CATALOGUE_CUSTOMPDF_RATE_LIMIT) -def build_custom_pdf(book_id, customizations, file_name): +def build_custom_pdf(book_id, customizations, file_name, waiter_id=None): """Builds a custom PDF file.""" - from django.core.files import File - from django.core.files.storage import DefaultStorage - from catalogue.models import Book - - print "will gen %s" % DefaultStorage().path(file_name) - if not DefaultStorage().exists(file_name): - kwargs = { - 'cover': True, - } - if 'no-cover' in customizations: - kwargs['cover'] = False - customizations.remove('no-cover') - pdf = Book.objects.get(pk=book_id).wldocument().as_pdf( - customizations=customizations, - morefloats=settings.LIBRARIAN_PDF_MOREFLOATS, - **kwargs) - DefaultStorage().save(file_name, File(open(pdf.get_filename()))) + try: + from django.core.files import File + from django.core.files.storage import DefaultStorage + from catalogue.models import Book + + print "will gen %s" % DefaultStorage().path(file_name) + if not DefaultStorage().exists(file_name): + kwargs = { + 'cover': True, + } + if 'no-cover' in customizations: + kwargs['cover'] = False + customizations.remove('no-cover') + pdf = Book.objects.get(pk=book_id).wldocument().as_pdf( + customizations=customizations, + morefloats=settings.LIBRARIAN_PDF_MOREFLOATS, + **kwargs) + DefaultStorage().save(file_name, File(open(pdf.get_filename()))) + finally: + if waiter_id is not None: + WaitedFile.objects.filter(pk=waiter_id).delete()