Commit fcc2d56d authored by delanoe's avatar delanoe

[FIX] sheduled function, still a bug.

parent c3c98fda
...@@ -74,12 +74,12 @@ def save( request , project_id ) : ...@@ -74,12 +74,12 @@ def save( request , project_id ) :
except ValueError: except ValueError:
raise Http404() raise Http404()
# do we have a valid project? # do we have a valid project?
project = session.query( Node ).filter(Node.id == project_id).first() project = session.query( Node ).filter(Node.id == project_id).first()
if project is None: if project is None:
raise Http404() raise Http404()
user = cache.User[request.user.id] user = cache.User[request.user.id]
if not user.owns(project): if not user.owns(project):
...@@ -132,12 +132,12 @@ def save( request , project_id ) : ...@@ -132,12 +132,12 @@ def save( request , project_id ) :
tasks.q.join() # wait until everything is finished tasks.q.join() # wait until everything is finished
dwnldsOK = 0 dwnldsOK = 0
for filename in tasks.firstResults : for filename in tasks.firstResults :
print(filename) print(filename)
if filename != False: if filename != False:
# add the uploaded resource to the corpus # add the uploaded resource to the corpus
corpus.add_resource( corpus.add_resource(
type = 3 type = 3
, path = filename , path = filename
) )
...@@ -146,7 +146,7 @@ def save( request , project_id ) : ...@@ -146,7 +146,7 @@ def save( request , project_id ) :
if dwnldsOK == 0 : if dwnldsOK == 0 :
return JsonHttpResponse(["fail"]) return JsonHttpResponse(["fail"])
try: try:
scheduled(parse_extract_indexhyperdata)(corpus_id) scheduled(parse_extract_indexhyperdata(corpus_id))
except Exception as error: except Exception as error:
print('WORKFLOW ERROR') print('WORKFLOW ERROR')
print(error) print(error)
......
...@@ -40,6 +40,6 @@ urlpatterns = [ url(r'^pubmed/query$' , pubmed.query ) ...@@ -40,6 +40,6 @@ urlpatterns = [ url(r'^pubmed/query$' , pubmed.query )
, url(r'^istex/save/(\d+)' , istex.save ) , url(r'^istex/save/(\d+)' , istex.save )
# TODO # TODO
#, url(r'^cern/query$' , cern.query ) #, url(r'^scoap3/query$' , cern.query )
#, url(r'^cern/save/(\d+)' , cern.save ) #, url(r'^scoap3/save/(\d+)' , cern.save )
] ]
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment