from traceback import print_exc
from celery.task import task
from django.conf import settings
+from wolnelektury.utils import localtime_to_utc
# TODO: move to model?
def touch_tag(tag):
update_dict = {
- 'book_count': tag.get_count(),
- 'changed_at': datetime.now(),
+ '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):
+def index_book(book_id, book_info=None, **kwargs):
from catalogue.models import Book
try:
- return Book.objects.get(id=book_id).search_index(book_info)
+ return Book.objects.get(id=book_id).search_index(book_info, **kwargs)
except Exception, e:
print "Exception during index: %s" % e
print_exc()