Spaces:
Running
Running
Update app.py
Browse files
app.py
CHANGED
@@ -14,6 +14,7 @@ HF_TOKEN = os.environ.get("HF_TOKEN") if os.environ.get("HF_TOKEN") else None #
|
|
14 |
|
15 |
|
16 |
nb_req_simult=80 ########
|
|
|
17 |
nb_gallery_model=5
|
18 |
|
19 |
|
@@ -502,16 +503,17 @@ def fonc_start(id_session,id_module,s,cont,list_models_to_gen):
|
|
502 |
for model_plus_tasks in cache_list_task[f"{id_session}"]:
|
503 |
if model_actu == "":
|
504 |
if model_plus_tasks["model"] in warm_models:
|
505 |
-
|
506 |
-
|
507 |
-
|
508 |
-
|
509 |
-
|
510 |
-
|
511 |
-
|
512 |
-
|
513 |
-
|
514 |
-
|
|
|
515 |
|
516 |
if model_actu == "":
|
517 |
for model_plus_tasks in cache_list_task[f"{id_session}"]:
|
|
|
14 |
|
15 |
|
16 |
nb_req_simult=80 ########
|
17 |
+
max_pending=8
|
18 |
nb_gallery_model=5
|
19 |
|
20 |
|
|
|
503 |
for model_plus_tasks in cache_list_task[f"{id_session}"]:
|
504 |
if model_actu == "":
|
505 |
if model_plus_tasks["model"] in warm_models:
|
506 |
+
if model_plus_tasks["pending_task"]<max_pending:
|
507 |
+
try:
|
508 |
+
task_actu=model_plus_tasks["task"].pop()
|
509 |
+
except:
|
510 |
+
continue
|
511 |
+
model_actu=model_plus_tasks["model"]
|
512 |
+
model_plus_tasks["pending_task"]+=1
|
513 |
+
use_warm_model=True
|
514 |
+
cache_text_actu[f"{id_session}"]["nb_warm_in_use"]+=1
|
515 |
+
print(f"warm model : {model_actu}\n")
|
516 |
+
break
|
517 |
|
518 |
if model_actu == "":
|
519 |
for model_plus_tasks in cache_list_task[f"{id_session}"]:
|