Update app.py

app.py

@@ -13,9 +13,9 @@ DASHSCOPE_API_KEY = os.getenv('DASHSCOPE_API_KEY')
 dashscope.api_key = DASHSCOPE_API_KEY
 
 KEEP_SUCCESS_TASK = 3600 * 10
-KEEP_RUNING_TASK = 3600 * 2
+KEEP_RUNING_TASK = 3600 * 1
 # the total running task number in 1800 seconds
-LIMIT_RUNING_TASK = 10
+LIMIT_RUNING_TASK = 4
 
 def t2v_generation(prompt, resolution, watermark_wan, seed = -1):
     seed = seed if seed >= 0 else random.randint(0, 2147483647)
@@ -102,10 +102,13 @@ task_status = {}
 
 def allow_task_num():
     num = 0
+    total_num = 0
     for task_id in task_status:
         if not task_status[task_id]["status"] and task_status[task_id]["time"] + 1800 > time.time():
             num += 1
-    return num < LIMIT_RUNING_TASK
+        if not task_status[task_id]["status"]:
+            total_num += 1
+    return num < LIMIT_RUNING_TASK or num < 10
 def clean_task_status():
     # clean the task over 1800 seconds
     for task_id in copy.deepcopy(task_status):
@@ -125,6 +128,10 @@ def cost_time(task_id):
         return f"{et:.2f}"
     else:
         return gr.Textbox()
+
+def waiting_time():
+    
+
 def get_process_bar(task_id, status):
     clean_task_status()
     if task_id not in task_status: