|
@@ -42,7 +42,7 @@ def video_start(platform):
|
|
|
elif platform == "bk":
|
|
elif platform == "bk":
|
|
|
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, 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}
|
|
|
for future in concurrent.futures.as_completed(futures):
|
|
for future in concurrent.futures.as_completed(futures):
|
|
|
try:
|
|
try:
|
|
|
future.result()
|
|
future.result()
|
|
@@ -55,7 +55,7 @@ def video_start(platform):
|
|
|
|
|
|
|
|
|
|
|
|
|
schedule.every().day.at("04:10").do(video_start, "cg")
|
|
schedule.every().day.at("04:10").do(video_start, "cg")
|
|
|
-schedule.every().day.at("19:40").do(video_start, "gs")
|
|
|
|
|
|
|
+schedule.every().day.at("19:50").do(video_start, "gs")
|
|
|
schedule.every().day.at("00:20").do(video_start, "bk")
|
|
schedule.every().day.at("00:20").do(video_start, "bk")
|
|
|
|
|
|
|
|
|
|
|
