|
@@ -491,7 +491,17 @@ def main():
|
|
|
json.dump(final_results, f, ensure_ascii=False, indent=2)
|
|
json.dump(final_results, f, ensure_ascii=False, indent=2)
|
|
|
|
|
|
|
|
print(f"💾 Scheduler results saved to: {output_file}")
|
|
print(f"💾 Scheduler results saved to: {output_file}")
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
|
|
+ # 收集文件处理结果
|
|
|
|
|
+ processed_files = []
|
|
|
|
|
+ processed_files = collect_processed_files(results)
|
|
|
|
|
+ output_file_processed = output_dir / f"processed_files_{args.num_processes}procs.csv"
|
|
|
|
|
+ with open(output_file_processed, 'w', encoding='utf-8') as f:
|
|
|
|
|
+ f.write("image_path,status\n")
|
|
|
|
|
+ for file_path, status in processed_files:
|
|
|
|
|
+ f.write(f"{file_path},{status}\n")
|
|
|
|
|
+ print(f"💾 Processed files saved to: {output_file_processed}")
|
|
|
|
|
+
|
|
|
return 0 if successful_processes == len(results) else 1
|
|
return 0 if successful_processes == len(results) else 1
|
|
|
|
|
|
|
|
except Exception as e:
|
|
except Exception as e:
|