|
@@ -102,8 +102,7 @@ def video_start(platform):
|
|
|
data = Material.feishu_bk_list()
|
|
data = Material.feishu_bk_list()
|
|
|
with concurrent.futures.ThreadPoolExecutor(max_workers=MAX_WORKERS) as executor:
|
|
with concurrent.futures.ThreadPoolExecutor(max_workers=MAX_WORKERS) as executor:
|
|
|
futures = {executor.submit(controlled_io_operation, platform, user_data): user_data for user_data in data}
|
|
futures = {executor.submit(controlled_io_operation, platform, user_data): user_data for user_data in data}
|
|
|
- timeout = 20 * 60 # 设置超时时间为20分钟
|
|
|
|
|
- for future in concurrent.futures.as_completed(futures, timeout=timeout):
|
|
|
|
|
|
|
+ for future in concurrent.futures.as_completed(futures):
|
|
|
try:
|
|
try:
|
|
|
future.result()
|
|
future.result()
|
|
|
print("处理结果: 成功")
|
|
print("处理结果: 成功")
|
|
@@ -130,7 +129,9 @@ schedule.every().day.at("00:10").do(bk_usernames_today)
|
|
|
|
|
|
|
|
schedule.every(10).minutes.do(video_start, "cg")
|
|
schedule.every(10).minutes.do(video_start, "cg")
|
|
|
schedule.every(10).minutes.do(video_start, "gs")
|
|
schedule.every(10).minutes.do(video_start, "gs")
|
|
|
-schedule.every(10).minutes.do(video_start, "bk")
|
|
|
|
|
|
|
+# schedule.every(10).minutes.do(video_start, "bk")
|
|
|
|
|
+schedule.every().day.at("00:20").do(video_start, "bk")
|
|
|
|
|
+
|
|
|
|
|
|
|
|
if __name__ == "__main__":
|
|
if __name__ == "__main__":
|
|
|
while True:
|
|
while True:
|
