脚本调试

job_fj.py

@@ -56,7 +56,7 @@ def video_start():
     data = Material.feishu_list()
     data = data[1]
     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, data)}
         for future in concurrent.futures.as_completed(futures):
             try:
                 future.result()

job_lq.py

@@ -56,7 +56,7 @@ def video_start():
     data = Material.feishu_list()
     data = data[4]
     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, data)}
         for future in concurrent.futures.as_completed(futures):
             try:
                 future.result()

job_lt.py

@@ -56,7 +56,7 @@ def video_start():
     data = Material.feishu_list()
     data = data[2]
     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, data)}
         for future in concurrent.futures.as_completed(futures):
             try:
                 future.result()

job_wxk.py

@@ -56,7 +56,7 @@ def video_start():
     data = Material.feishu_list()
     data = data[0]
     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, data)}
         for future in concurrent.futures.as_completed(futures):
             try:
                 future.result()

job_wxk1.py

@@ -56,7 +56,7 @@ def video_start():
     data = Material.feishu_list()
     data = data[5]
     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, data)}
         for future in concurrent.futures.as_completed(futures):
             try:
                 future.result()

job_yht.py

@@ -56,7 +56,7 @@ def video_start():
     data = Material.feishu_list()
     data = data[3]
     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, data)}
         for future in concurrent.futures.as_completed(futures):
             try:
                 future.result()