fnp
/
wolnelektury.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Tag description update API
[wolnelektury.git]
/
src
/
catalogue
/
tasks.py
diff --git
a/src/catalogue/tasks.py
b/src/catalogue/tasks.py
index
499e8e6
..
b703e17
100644
(file)
--- a/
src/catalogue/tasks.py
+++ b/
src/catalogue/tasks.py
@@
-2,12
+2,12
@@
# Copyright © Fundacja Nowoczesna Polska. See NOTICE for more information.
#
from traceback import print_exc
# Copyright © Fundacja Nowoczesna Polska. See NOTICE for more information.
#
from traceback import print_exc
-from celery
.task import
task
+from celery
import shared_
task
from celery.utils.log import get_task_logger
from django.conf import settings
from django.utils import timezone
from celery.utils.log import get_task_logger
from django.conf import settings
from django.utils import timezone
-from catalogue.utils import
gallery_path
+from catalogue.utils import
absolute_url, gallery_url
from waiter.models import WaitedFile
task_logger = get_task_logger(__name__)
from waiter.models import WaitedFile
task_logger = get_task_logger(__name__)
@@
-22,7
+22,7
@@
def touch_tag(tag):
type(tag).objects.filter(pk=tag.pk).update(**update_dict)
type(tag).objects.filter(pk=tag.pk).update(**update_dict)
-@task
+@
shared_
task
def index_book(book_id, book_info=None, **kwargs):
from catalogue.models import Book
try:
def index_book(book_id, book_info=None, **kwargs):
from catalogue.models import Book
try:
@@
-33,7
+33,7
@@
def index_book(book_id, book_info=None, **kwargs):
raise e
raise e
-@task(ignore_result=True, rate_limit=settings.CATALOGUE_CUSTOMPDF_RATE_LIMIT)
+@
shared_
task(ignore_result=True, rate_limit=settings.CATALOGUE_CUSTOMPDF_RATE_LIMIT)
def build_custom_pdf(book_id, customizations, file_name, waiter_id=None):
"""Builds a custom PDF file."""
try:
def build_custom_pdf(book_id, customizations, file_name, waiter_id=None):
"""Builds a custom PDF file."""
try:
@@
-53,7
+53,7
@@
def build_custom_pdf(book_id, customizations, file_name, waiter_id=None):
pdf = wldoc.as_pdf(
customizations=customizations,
morefloats=settings.LIBRARIAN_PDF_MOREFLOATS,
pdf = wldoc.as_pdf(
customizations=customizations,
morefloats=settings.LIBRARIAN_PDF_MOREFLOATS,
-
ilustr_path=gallery_path(wldoc.book_info.url.slug
),
+
base_url=absolute_url(gallery_url(wldoc.book_info.url.slug)
),
**kwargs)
DefaultStorage().save(file_name, File(open(pdf.get_filename(), 'rb')))
finally:
**kwargs)
DefaultStorage().save(file_name, File(open(pdf.get_filename(), 'rb')))
finally:
@@
-61,13
+61,13
@@
def build_custom_pdf(book_id, customizations, file_name, waiter_id=None):
WaitedFile.objects.filter(pk=waiter_id).delete()
WaitedFile.objects.filter(pk=waiter_id).delete()
-@task(ignore_result=True)
+@
shared_
task(ignore_result=True)
def update_counters():
from .helpers import update_counters
update_counters()
def update_counters():
from .helpers import update_counters
update_counters()
-@task(ignore_result=True)
+@
shared_
task(ignore_result=True)
def update_references(book_id):
from catalogue.models import Book
Book.objects.get(id=book_id).update_references()
def update_references(book_id):
from catalogue.models import Book
Book.objects.get(id=book_id).update_references()