matthias/mayan-edms
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Update task and function names

Browse Source
This commit is contained in:
Roberto Rosario
2015-01-03 12:33:33 -04:00
parent bca6355bb8
commit ef140ac2f7
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
mayan/apps/document_indexing/tasks.py
View File

@@ -4,7 +4,7 @@ from mayan.celery import app
from documents.models import Document from documents.models import Document
from lock_manager import Lock, LockError from lock_manager import Lock, LockError
from .api import update_indexes, delete_empty_index_nodes from .api import index_document, delete_empty_index_nodes
from .tools import do_rebuild_all_indexes from .tools import do_rebuild_all_indexes
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
@@ -17,7 +17,7 @@ def task_delete_empty_index_nodes():
@app.task(bind=True, ignore_result=True) @app.task(bind=True, ignore_result=True)
def task_update_indexes(self, document_id): def task_index_document(self, document_id):
# TODO: Add concurrent task control # TODO: Add concurrent task control
try: try:
lock = Lock.acquire_lock('document_indexing_task_update_index_document_%d' % document_id) lock = Lock.acquire_lock('document_indexing_task_update_index_document_%d' % document_id)
@@ -31,7 +31,9 @@ def task_update_indexes(self, document_id):
# Document was deleted before we could execute, abort about updating # Document was deleted before we could execute, abort about updating
pass pass
else: else:
update_indexes(document) index_document(document)
finally:
lock.release()
@app.task(ignore_result=True) @app.task(ignore_result=True)