zhangyong vor 11 Monaten
Ursprung
Commit
392ad870aa
3 geänderte Dateien mit 3 neuen und 3 gelöschten Zeilen
  1. 1 1
      agc_assign_main.py
  2. 1 1
      agc_bk_main.py
  3. 1 1
      agc_main.py

+ 1 - 1
agc_assign_main.py

@@ -56,7 +56,7 @@ def video_task():
         # 设置超时时间为20分钟
         # 设置超时时间为20分钟
         timeout = 25 * 60
         timeout = 25 * 60
         # 等待所有任务执行完成或超时
         # 等待所有任务执行完成或超时
-        for future in concurrent.futures.as_completed(futures, timeout=timeout):
+        for future in concurrent.futures.as_completed(futures):
             try:
             try:
                 # 获取每个任务的执行结果
                 # 获取每个任务的执行结果
                 result = future.result()
                 result = future.result()

+ 1 - 1
agc_bk_main.py

@@ -45,7 +45,7 @@ def video_task():
         # 设置超时时间为360分钟
         # 设置超时时间为360分钟
         timeout = 360 * 60
         timeout = 360 * 60
         # 等待所有任务执行完成或超时
         # 等待所有任务执行完成或超时
-        for future in concurrent.futures.as_completed(futures, timeout=timeout):
+        for future in concurrent.futures.as_completed(futures):
             try:
             try:
                 # 获取每个任务的执行结果
                 # 获取每个任务的执行结果
                 result = future.result()
                 result = future.result()

+ 1 - 1
agc_main.py

@@ -43,7 +43,7 @@ def video_task():
         # 设置超时时间为20分钟
         # 设置超时时间为20分钟
         timeout = 25 * 60
         timeout = 25 * 60
         # 等待所有任务执行完成或超时
         # 等待所有任务执行完成或超时
-        for future in concurrent.futures.as_completed(futures, timeout=timeout):
+        for future in concurrent.futures.as_completed(futures):
             try:
             try:
                 # 获取每个任务的执行结果
                 # 获取每个任务的执行结果
                 result = future.result()
                 result = future.result()