Spaces:
Paused
Paused
Update app.py
Browse files
app.py
CHANGED
|
@@ -10,16 +10,25 @@ app = FastAPI()
|
|
| 10 |
|
| 11 |
@app.get("/")
|
| 12 |
def start_train():
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 13 |
#space_variables = API.get_space_variables(repo_id=REPO_ID)
|
| 14 |
#if 'STATUS' not in space_variables or space_variables['STATUS'] != 'COMPUTING':
|
| 15 |
# print("Beginning processing.")
|
| 16 |
# API.add_space_variable(repo_id=REPO_ID, key='STATUS', value='COMPUTING')
|
| 17 |
-
os.system(f"./entrypoint.sh {REPO_ID}")
|
| 18 |
#API.add_space_variable(repo_id=REPO_ID, key='STATUS', value='NOT_COMPUTING')
|
| 19 |
-
|
| 20 |
-
|
| 21 |
-
|
| 22 |
-
if curr_runtime != "cpu-basic":
|
| 23 |
-
API.request_space_hardware(repo_id=REPO_ID, hardware="cpu-basic")
|
| 24 |
-
|
| 25 |
-
return {"Status": "whatever"}#space_variables['STATUS']}
|
|
|
|
| 10 |
|
| 11 |
@app.get("/")
|
| 12 |
def start_train():
|
| 13 |
+
model_file = open("models.txt", "r+").readlines()
|
| 14 |
+
task_file = open("tasks.txt", "r+").readlines()
|
| 15 |
+
hardware_file = open("hardware.txt", "r+").readlines()
|
| 16 |
+
for hardware in hardware_file:
|
| 17 |
+
hardware = hardware.strip()
|
| 18 |
+
curr_runtime = API.get_space_runtime(repo_id=REPO_ID)
|
| 19 |
+
if curr_runtime != hardware:
|
| 20 |
+
API.request_space_hardware(repo_id=REPO_ID, hardware=hardware)
|
| 21 |
+
for model in model_file:
|
| 22 |
+
model = model.strip()
|
| 23 |
+
for task in task_file:
|
| 24 |
+
task = task.strip()
|
| 25 |
+
os.system(f"./entrypoint.sh {REPO_ID} {model} {task} {hardware}")
|
| 26 |
#space_variables = API.get_space_variables(repo_id=REPO_ID)
|
| 27 |
#if 'STATUS' not in space_variables or space_variables['STATUS'] != 'COMPUTING':
|
| 28 |
# print("Beginning processing.")
|
| 29 |
# API.add_space_variable(repo_id=REPO_ID, key='STATUS', value='COMPUTING')
|
| 30 |
+
#os.system(f"./entrypoint.sh {REPO_ID} {model} {task} {hardware}")
|
| 31 |
#API.add_space_variable(repo_id=REPO_ID, key='STATUS', value='NOT_COMPUTING')
|
| 32 |
+
print("Pausing space")
|
| 33 |
+
API.pause_space(REPO_ID)
|
| 34 |
+
return {"Status": "Done"}#space_variables['STATUS']}
|
|
|
|
|
|
|
|
|
|
|
|