Spaces:
Sleeping
Sleeping
Commit
·
200e8a2
1
Parent(s):
493b797
Upload app.py with huggingface_hub
Browse files
app.py
CHANGED
|
@@ -24,13 +24,15 @@ def put():
|
|
| 24 |
key = d['key']
|
| 25 |
if not get_key_sha256(key) == match_sha256:
|
| 26 |
return 'err'
|
| 27 |
-
machine_type = d
|
| 28 |
job = d['job']
|
| 29 |
sha256 = get_key_sha256(job)
|
| 30 |
folder = os.path.join(data_folder, 'new', machine_type)
|
| 31 |
doing_folder = os.path.join(data_folder, 'doing', machine_type)
|
|
|
|
| 32 |
os.makedirs(folder, exist_ok=True)
|
| 33 |
os.makedirs(doing_folder, exist_ok=True)
|
|
|
|
| 34 |
file = os.path.join(folder, sha256)
|
| 35 |
open(file, 'w').write(job)
|
| 36 |
return 'ok'
|
|
@@ -59,9 +61,9 @@ def get():
|
|
| 59 |
os.remove(source_file)
|
| 60 |
except:
|
| 61 |
print('deleteerr')
|
| 62 |
-
return txt
|
| 63 |
|
| 64 |
-
@app.route("/done", methods = ['
|
| 65 |
def done():
|
| 66 |
d = request.json
|
| 67 |
key = d['key']
|
|
@@ -69,6 +71,7 @@ def done():
|
|
| 69 |
return 'err'
|
| 70 |
sha256 = d['sha256']
|
| 71 |
machine_type = d['machine_type']
|
|
|
|
| 72 |
file = os.path.join(data_folder, 'doing', machine_type, sha256)
|
| 73 |
try:
|
| 74 |
os.remove(file)
|
|
@@ -88,7 +91,6 @@ def get_folder_list(folder, full=False):
|
|
| 88 |
dd[f] = open(os.path.join(folder, machine_type, f)).read()
|
| 89 |
d[machine_type] = dd
|
| 90 |
else:
|
| 91 |
-
|
| 92 |
d[machine_type] = fs
|
| 93 |
return d
|
| 94 |
|
|
|
|
| 24 |
key = d['key']
|
| 25 |
if not get_key_sha256(key) == match_sha256:
|
| 26 |
return 'err'
|
| 27 |
+
machine_type = d.get('machine_type', 'default')
|
| 28 |
job = d['job']
|
| 29 |
sha256 = get_key_sha256(job)
|
| 30 |
folder = os.path.join(data_folder, 'new', machine_type)
|
| 31 |
doing_folder = os.path.join(data_folder, 'doing', machine_type)
|
| 32 |
+
done_folder = os.path.join(data_folder, 'done', machine_type)
|
| 33 |
os.makedirs(folder, exist_ok=True)
|
| 34 |
os.makedirs(doing_folder, exist_ok=True)
|
| 35 |
+
os.makedirs(done_folder, exist_ok=True)
|
| 36 |
file = os.path.join(folder, sha256)
|
| 37 |
open(file, 'w').write(job)
|
| 38 |
return 'ok'
|
|
|
|
| 61 |
os.remove(source_file)
|
| 62 |
except:
|
| 63 |
print('deleteerr')
|
| 64 |
+
return json.dumps({'sha256': file, 'job': txt})
|
| 65 |
|
| 66 |
+
@app.route("/done", methods = ['POST'])
|
| 67 |
def done():
|
| 68 |
d = request.json
|
| 69 |
key = d['key']
|
|
|
|
| 71 |
return 'err'
|
| 72 |
sha256 = d['sha256']
|
| 73 |
machine_type = d['machine_type']
|
| 74 |
+
output = d['output']
|
| 75 |
file = os.path.join(data_folder, 'doing', machine_type, sha256)
|
| 76 |
try:
|
| 77 |
os.remove(file)
|
|
|
|
| 91 |
dd[f] = open(os.path.join(folder, machine_type, f)).read()
|
| 92 |
d[machine_type] = dd
|
| 93 |
else:
|
|
|
|
| 94 |
d[machine_type] = fs
|
| 95 |
return d
|
| 96 |
|