Commit 76298b45 authored by PkSM3's avatar PkSM3

[UPDATE] ensure temp user-dir if not exists

parent ae23856c
...@@ -83,6 +83,11 @@ class MedlineFetcher: ...@@ -83,6 +83,11 @@ class MedlineFetcher:
eFetch = '%s/efetch.fcgi?email=youremail@example.org&rettype=%s&retmode=xml&retstart=%s&retmax=%s&db=%s&query_key=%s&WebEnv=%s' %(self.pubMedEutilsURL, self.reportType, retstart, retmax, self.pubMedDB, queryKey, webEnv) eFetch = '%s/efetch.fcgi?email=youremail@example.org&rettype=%s&retmode=xml&retstart=%s&retmax=%s&db=%s&query_key=%s&WebEnv=%s' %(self.pubMedEutilsURL, self.reportType, retstart, retmax, self.pubMedDB, queryKey, webEnv)
return eFetch return eFetch
def ensure_dir(self , f):
d = os.path.dirname(f)
if not os.path.exists(d):
os.makedirs(d)
# generic! # generic!
def downloadFile(self, item): def downloadFile(self, item):
url = item[0] url = item[0]
......
...@@ -15,6 +15,7 @@ import json ...@@ -15,6 +15,7 @@ import json
from gargantext_web.settings import MEDIA_ROOT from gargantext_web.settings import MEDIA_ROOT
from datetime import datetime from datetime import datetime
import time import time
import os
import threading import threading
from django.core.files import File from django.core.files import File
from gargantext_web.settings import DEBUG from gargantext_web.settings import DEBUG
...@@ -83,6 +84,7 @@ def doTheQuery(request , project_id): ...@@ -83,6 +84,7 @@ def doTheQuery(request , project_id):
try: try:
tasks = MedlineFetcher() tasks = MedlineFetcher()
tasks.ensure_dir ( MEDIA_ROOT + '/corpora/'+str(request.user)+"/" )
# configuring your queue with the event # configuring your queue with the event
for i in range(8): for i in range(8):
t = threading.Thread(target=tasks.worker2) #thing to do t = threading.Thread(target=tasks.worker2) #thing to do
......
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